ACCUMULO-2112 clear the bad server list of any server that is communicating
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/f56ae10b Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/f56ae10b Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/f56ae10b Branch: refs/heads/1.5.1-SNAPSHOT Commit: f56ae10b3e72e6d03fa6324afcd23619ea94b7b9 Parents: 7547b29 Author: Eric Newton <eric.new...@gmail.com> Authored: Mon Dec 30 13:15:52 2013 -0500 Committer: Eric Newton <eric.new...@gmail.com> Committed: Mon Dec 30 13:15:52 2013 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/accumulo/server/master/Master.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/f56ae10b/src/server/src/main/java/org/apache/accumulo/server/master/Master.java ---------------------------------------------------------------------- diff --git a/src/server/src/main/java/org/apache/accumulo/server/master/Master.java b/src/server/src/main/java/org/apache/accumulo/server/master/Master.java index 9970ee8..c8f31fe 100644 --- a/src/server/src/main/java/org/apache/accumulo/server/master/Master.java +++ b/src/server/src/main/java/org/apache/accumulo/server/master/Master.java @@ -2061,6 +2061,7 @@ public class Master implements LiveTServerSet.Listener, LoggerWatcher, TableObse } synchronized (badServers) { badServers.keySet().retainAll(currentServers); + badServers.keySet().removeAll(result.keySet()); } log.debug(String.format("Finished gathering information from %d servers in %.2f seconds", result.size(), (System.currentTimeMillis() - start) / 1000.)); return result;
