You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/12/17 21:04:00 UTC
[03/10] git commit: ACCUMULO-2037 host:port[123456] sorts before
host:port[], so the correct host was being skipped
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.6.0-SNAPSHOT
Commit: bec36bc3f4164dbb5bceb9b558b0aa9b0ae150c4
Parents: 59932f6
Author: Eric Newton <er...@gmail.com>
Authored: Tue Dec 17 15:03:04 2013 -0500
Committer: Eric Newton <er...@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();