ACCUMULO-3423 mark logs as closed when tablet servers die
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b5004a1c Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b5004a1c Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b5004a1c Branch: refs/heads/master Commit: b5004a1c4c518f89deb457e987f228ccf9bf0d5b Parents: e446f0a Author: Eric C. Newton <eric.new...@gmail.com> Authored: Mon Jun 15 17:52:24 2015 -0400 Committer: Eric C. Newton <eric.new...@gmail.com> Committed: Mon Jun 15 17:52:24 2015 -0400 ---------------------------------------------------------------------- server/master/src/main/java/org/apache/accumulo/master/Master.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/b5004a1c/server/master/src/main/java/org/apache/accumulo/master/Master.java ---------------------------------------------------------------------- diff --git a/server/master/src/main/java/org/apache/accumulo/master/Master.java b/server/master/src/main/java/org/apache/accumulo/master/Master.java index 0cf84f2..95f3f4e 100644 --- a/server/master/src/main/java/org/apache/accumulo/master/Master.java +++ b/server/master/src/main/java/org/apache/accumulo/master/Master.java @@ -1593,7 +1593,7 @@ public class Master extends AccumuloServerContext implements LiveTServerSet.List WalStateManager mgr = new WalStateManager(this.inst, ZooReaderWriter.getInstance()); for (Entry<TServerInstance,List<Path>> server : logsForDeadServers.entrySet()) { for (Path path : server.getValue()) { - mgr.closeWal(server.getKey(), path); + mgr.closeWal(server.getKey(), path); } } }
