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.5.1-SNAPSHOT Commit: bec36bc3f4164dbb5bceb9b558b0aa9b0ae150c4 Parents: 59932f6 Author: Eric Newton <eric.new...@gmail.com> Authored: Tue Dec 17 15:03:04 2013 -0500 Committer: Eric Newton <eric.new...@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();
