From fa68470fe656d2adbda31767908e37da3aa9fc7c Mon Sep 17 00:00:00 2001 From: Enis Soztutar Date: Wed, 12 Mar 2014 22:45:06 +0000 Subject: [PATCH 21/45] HBASE-10620 LoadBalancer.needsBalance() should check for co-located region replicas as well (Addendum patch to fix return value from balance() call) git-svn-id: https://svn.apache.org/repos/asf/hbase/branches/hbase-10070@1576975 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/hadoop/hbase/master/HMaster.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java index 226ab55..f06948e 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java @@ -954,7 +954,6 @@ public class HMaster extends HRegionServer implements MasterServices, Server { } // Do this call outside of synchronized block. int maximumBalanceTime = getBalancerCutoffTime(); - boolean balancerRan; synchronized (this.balancer) { // If balance not true, don't run balancer. if (!this.loadBalancerTracker.isBalancerOn()) return false; @@ -998,7 +997,6 @@ public class HMaster extends HRegionServer implements MasterServices, Server { long cutoffTime = System.currentTimeMillis() + maximumBalanceTime; int rpCount = 0; // number of RegionPlans balanced so far long totalRegPlanExecTime = 0; - balancerRan = plans.size() != 0; if (plans != null && !plans.isEmpty()) { for (RegionPlan plan: plans) { LOG.info("balance " + plan); @@ -1026,7 +1024,9 @@ public class HMaster extends HRegionServer implements MasterServices, Server { } } } - return balancerRan; + // If LoadBalancer did not generate any plans, it means the cluster is already balanced. + // Return true indicating a success. + return true; } /** -- 2.0.0