Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25006 Make the cost functions optional for StochastoicBalancer 

Closes #2386

Signed-off-by: Nick Dimiduk <ndimiduk@apache.org>
Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
Clara Xiong 2020-09-13 14:10:58 +05:30 committed by Viraj Jasani
parent e5ca9adc54
commit fe776306d0
No known key found for this signature in database
GPG Key ID: B3D6C0B41C8ADFD5
1 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -205,19 +205,19 @@ public class StochasticLoadBalancer extends BaseLoadBalancer {
regionReplicaRackCostFunction = new RegionReplicaRackCostFunction(conf); regionReplicaRackCostFunction = new RegionReplicaRackCostFunction(conf);
costFunctions = new ArrayList<>(); costFunctions = new ArrayList<>();
costFunctions.add(new RegionCountSkewCostFunction(conf)); addCostFunction(new RegionCountSkewCostFunction(conf));
costFunctions.add(new PrimaryRegionCountSkewCostFunction(conf)); addCostFunction(new PrimaryRegionCountSkewCostFunction(conf));
costFunctions.add(new MoveCostFunction(conf)); addCostFunction(new MoveCostFunction(conf));
costFunctions.add(localityCost); addCostFunction(localityCost);
costFunctions.add(rackLocalityCost); addCostFunction(rackLocalityCost);
costFunctions.add(new TableSkewCostFunction(conf)); addCostFunction(new TableSkewCostFunction(conf));
costFunctions.add(regionReplicaHostCostFunction); addCostFunction(regionReplicaHostCostFunction);
costFunctions.add(regionReplicaRackCostFunction); addCostFunction(regionReplicaRackCostFunction);
costFunctions.add(regionLoadFunctions[0]); addCostFunction(regionLoadFunctions[0]);
costFunctions.add(regionLoadFunctions[1]); addCostFunction(regionLoadFunctions[1]);
costFunctions.add(regionLoadFunctions[2]); addCostFunction(regionLoadFunctions[2]);
costFunctions.add(regionLoadFunctions[3]); addCostFunction(regionLoadFunctions[3]);
costFunctions.add(regionLoadFunctions[4]); addCostFunction(regionLoadFunctions[4]);
loadCustomCostFunctions(conf); loadCustomCostFunctions(conf);
curFunctionCosts= new Double[costFunctions.size()]; curFunctionCosts= new Double[costFunctions.size()];
@ -514,6 +514,12 @@ public class StochasticLoadBalancer extends BaseLoadBalancer {
} }
} }
private void addCostFunction(CostFunction costFunction) {
if (costFunction.getMultiplier() > 0) {
costFunctions.add(costFunction);
}
}
private String functionCost() { private String functionCost() {
StringBuilder builder = new StringBuilder(); StringBuilder builder = new StringBuilder();
for (CostFunction c:costFunctions) { for (CostFunction c:costFunctions) {