accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [01/10] git commit: ACCUMULO-2037 host:port[123456] sorts before host:port[], so the correct host was being skipped
Date Tue, 17 Dec 2013 20:03:58 GMT
Updated Branches:
  refs/heads/1.4.5-SNAPSHOT 59932f6d2 -> bec36bc3f
  refs/heads/1.5.1-SNAPSHOT 3458bfaec -> 144d9d5bf
  refs/heads/1.6.0-SNAPSHOT 44a916636 -> 46585ab59
  refs/heads/master 6e641f43e -> 190e0b5f7


ACCUMULO-2037 host:port[123456] sorts before host:port[], so the correct host was being skipped


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

Branch: refs/heads/1.4.5-SNAPSHOT
Commit: bec36bc3f4164dbb5bceb9b558b0aa9b0ae150c4
Parents: 59932f6
Author: Eric Newton <eric.newton@gmail.com>
Authored: Tue Dec 17 15:03:04 2013 -0500
Committer: Eric Newton <eric.newton@gmail.com>
Committed: Tue Dec 17 15:03:04 2013 -0500

----------------------------------------------------------------------
 .../accumulo/server/master/balancer/DefaultLoadBalancer.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/bec36bc3/src/server/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java
b/src/server/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java
index 27e232d..4826097 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java
@@ -62,7 +62,8 @@ public class DefaultLoadBalancer extends TabletBalancer {
     
     if (last != null) {
       // Maintain locality
-      TServerInstance simple = new TServerInstance(last.getLocation(), "");
+      String fakeSessionID = " ";
+      TServerInstance simple = new TServerInstance(last.getLocation(), fakeSessionID);
       Iterator<TServerInstance> find = locations.tailMap(simple).keySet().iterator();
       if (find.hasNext()) {
         TServerInstance current = find.next();


Mime
View raw message