accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/2] accumulo git commit: ACCUMULO-3441 use the proper TServerStatus object to update current instances
Date Mon, 22 Dec 2014 19:35:44 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master 095d641e5 -> 87a22dd09


ACCUMULO-3441 use the proper TServerStatus object to update current instances


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/00d758d1
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/00d758d1
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/00d758d1

Branch: refs/heads/master
Commit: 00d758d17aa380bf42a69bf2795aead6eced9a22
Parents: b6f9a1e
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Mon Dec 22 14:34:32 2014 -0500
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Mon Dec 22 14:34:32 2014 -0500

----------------------------------------------------------------------
 .../java/org/apache/accumulo/server/master/LiveTServerSet.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/00d758d1/server/base/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
----------------------------------------------------------------------
diff --git a/server/base/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
b/server/base/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
index 002389a..16f9885 100644
--- a/server/base/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
+++ b/server/base/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
@@ -308,7 +308,8 @@ public class LiveTServerSet implements Watcher {
         updates.add(instance);
         TServerInfo tServerInfo = new TServerInfo(instance, new TServerConnection(client));
         current.put(zPath, tServerInfo);
-        currentInstances.put(info.instance, tServerInfo);
+        currentInstances.remove(info.instance);
+        currentInstances.put(instance, tServerInfo);
       }
     }
   }


Mime
View raw message