Skip to content

Commit 1901a33

Browse files
committed
merge conflict fix
1 parent e231cca commit 1901a33

File tree

3 files changed

+5
-6
lines changed

3 files changed

+5
-6
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1034,10 +1034,10 @@ public String toString() {
10341034
}
10351035

10361036
private double getSkewChangeFor(int serverIndex, int tableIndex, double regionCountChange) {
1037-
double curSkew = Math
1038-
.abs(numRegionsPerServerPerTable[serverIndex][tableIndex] - meanRegionsPerTable[tableIndex]);
1039-
double oldSkew = Math.abs(
1040-
numRegionsPerServerPerTable[serverIndex][tableIndex] - regionCountChange - meanRegionsPerTable[tableIndex]);
1037+
double curSkew = Math.abs(numRegionsPerServerPerTable[serverIndex][tableIndex] -
1038+
meanRegionsPerTable[tableIndex]);
1039+
double oldSkew = Math.abs(numRegionsPerServerPerTable[serverIndex][tableIndex] -
1040+
regionCountChange - meanRegionsPerTable[tableIndex]);
10411041
return curSkew - oldSkew;
10421042
}
10431043
}

hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1508,7 +1508,6 @@ public static String composeAttributeName(String tableName, String costFunctionN
15081508
* @param max The Max value
15091509
* @param value The value to be scaled.
15101510
* @return The scaled value.
1511-
* TBD: To be refactored to CostFunction when cost funtion is refactored out
15121511
*/
15131512
static double scale(double min, double max, double value) {
15141513
if (max <= min || value <= min

hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestStochasticLoadBalancerBalanceCluster.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public class TestStochasticLoadBalancerBalanceCluster extends BalancerTestBase {
5151
*/
5252
@Test
5353
public void testBalanceCluster() throws Exception {
54-
conf.setLong("hbase.master.balancer.stochastic.maxRunningTime", 3 * 60 * 1000); // 3 min
54+
conf.setLong("hbase.master.balancer.stochastic.maxRunningTime", 300 * 1000); // 300 sec
5555
conf.setFloat("hbase.master.balancer.stochastic.maxMovePercent", 1.0f);
5656
loadBalancer.setConf(conf);
5757
for (int[] mockCluster : clusterStateMocks) {

0 commit comments

Comments
 (0)