This is an automated email from the ASF dual-hosted git repository.

ctubbsii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git

commit c876275d421d8e4bf3f22321294f0cf4a72caad1
Merge: f39c2fe 6ae7ddb
Author: Christopher Tubbs <ctubb...@apache.org>
AuthorDate: Thu Aug 15 15:45:42 2019 -0400

    Merge branch '2.0'

 .../accumulo/gc/GarbageCollectWriteAheadLogs.java      | 10 ++++------
 .../org/apache/accumulo/gc/SimpleGarbageCollector.java | 15 ++++++++++++++-
 .../accumulo/gc/GarbageCollectWriteAheadLogsTest.java  | 18 ++++++++++++++++++
 3 files changed, 36 insertions(+), 7 deletions(-)

diff --cc 
server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
index 5637a8d,e671219..2858bf6
--- 
a/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
+++ 
b/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
@@@ -89,13 -90,9 +90,9 @@@ public class GarbageCollectWriteAheadLo
      this.context = context;
      this.fs = fs;
      this.useTrash = useTrash;
-     this.liveServers = new LiveTServerSet(context, (current, deleted, added) 
-> {
-       log.debug("New tablet servers noticed: {}", added);
-       log.debug("Tablet servers removed: {}", deleted);
-     });
-     liveServers.startListeningForTabletServerChanges();
+     this.liveServers = liveServers;
      this.walMarker = new WalStateManager(context);
 -    this.store = () -> Iterators.concat(new 
ZooTabletStateStore(context).iterator(),
 +    this.store = () -> Iterators.concat(new 
ZooTabletStateStore(context.getAmple()).iterator(),
          new RootTabletStateStore(context).iterator(), new 
MetaDataStateStore(context).iterator());
    }
  

Reply via email to