HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange should chain the request to internal balancer (#3209)
Signed-off-by: Yulin Niu <niuyulin@apache.org>
This commit is contained in:
parent
6c65314cdf
commit
73a82bd7c6
|
@ -409,12 +409,14 @@ public class RSGroupBasedLoadBalancer implements LoadBalancer {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onConfigurationChange(Configuration conf) {
|
public void onConfigurationChange(Configuration conf) {
|
||||||
|
this.config = conf;
|
||||||
boolean newFallbackEnabled = conf.getBoolean(FALLBACK_GROUP_ENABLE_KEY, false);
|
boolean newFallbackEnabled = conf.getBoolean(FALLBACK_GROUP_ENABLE_KEY, false);
|
||||||
if (fallbackEnabled != newFallbackEnabled) {
|
if (fallbackEnabled != newFallbackEnabled) {
|
||||||
LOG.info("Changing the value of {} from {} to {}", FALLBACK_GROUP_ENABLE_KEY,
|
LOG.info("Changing the value of {} from {} to {}", FALLBACK_GROUP_ENABLE_KEY,
|
||||||
fallbackEnabled, newFallbackEnabled);
|
fallbackEnabled, newFallbackEnabled);
|
||||||
fallbackEnabled = newFallbackEnabled;
|
fallbackEnabled = newFallbackEnabled;
|
||||||
}
|
}
|
||||||
|
internalBalancer.onConfigurationChange(conf);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue