You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jg...@apache.org on 2009/08/26 00:43:17 UTC
svn commit: r807845 - in /hadoop/hbase/branches/0.20: CHANGES.txt
src/java/org/apache/hadoop/hbase/master/RegionManager.java
Author: jgray
Date: Tue Aug 25 22:43:16 2009
New Revision: 807845
URL: http://svn.apache.org/viewvc?rev=807845&view=rev
Log:
HBASE-1737 Regions unbalanced when adding new node (recommit)
Modified:
hadoop/hbase/branches/0.20/CHANGES.txt
hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/master/RegionManager.java
Modified: hadoop/hbase/branches/0.20/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.20/CHANGES.txt?rev=807845&r1=807844&r2=807845&view=diff
==============================================================================
--- hadoop/hbase/branches/0.20/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.20/CHANGES.txt Tue Aug 25 22:43:16 2009
@@ -327,6 +327,7 @@
hudson too
HBASE-1791 Timeout in IndexRecordWriter (Bradford Stephens via Andrew
Purtell)
+ HBASE-1737 Regions unbalanced when adding new node (recommit)
IMPROVEMENTS
HBASE-1089 Add count of regions on filesystem to master UI; add percentage
Modified: hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/master/RegionManager.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/master/RegionManager.java?rev=807845&r1=807844&r2=807845&view=diff
==============================================================================
--- hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/master/RegionManager.java (original)
+++ hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/master/RegionManager.java Tue Aug 25 22:43:16 2009
@@ -1349,19 +1349,24 @@
double avg = master.serverManager.getAverageLoad();
// nothing to balance if server load not more then average load
- if (servLoad.getLoad() <= Math.ceil(avg) || avg <= 2.0) return;
+ if(servLoad.getLoad() <= Math.ceil(avg) || avg <= 2.0) {
+ return;
+ }
- // check if server is overloaded
+ // check if current server is overloaded
int numRegionsToClose = balanceFromOverloaded(servLoad, avg);
// check if we can unload server by low loaded servers
- if (numRegionsToClose <= 0)
- balanceToLowloaded(info.getServerName(), servLoad, avg);
+ if(numRegionsToClose <= 0) {
+ numRegionsToClose = balanceToLowloaded(info.getServerName(), servLoad,
+ avg);
+ }
- if (maxRegToClose > 0)
+ if(maxRegToClose > 0) {
numRegionsToClose = Math.min(numRegionsToClose, maxRegToClose);
-
- if (numRegionsToClose > 0){
+ }
+
+ if(numRegionsToClose > 0) {
unassignSomeRegions(info, numRegionsToClose, mostLoadedRegions,
returnMsgs);
}
@@ -1416,7 +1421,8 @@
if (LOG.isDebugEnabled()) {
LOG.debug("Server " + srvName + " will be unloaded for " +
"balance. Server load: " + numSrvRegs + " avg: " +
- avgLoad + ", regions can be moved: " + numMoveToLowLoaded);
+ avgLoad + ", regions can be moved: " + numMoveToLowLoaded +
+ ". Regions to close: " + numRegionsToClose);
}
return numRegionsToClose;
}