From a7814bbe57899aabb66b2605592acfd55d31f63e Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Fri, 30 Apr 2021 22:45:33 +0800 Subject: [PATCH] HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange should chain the request to internal balancer (#3209) Signed-off-by: Yulin Niu --- .../apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java index 901aafa7a5a..0fd522477df 100644 --- a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java +++ b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java @@ -395,12 +395,14 @@ public class RSGroupBasedLoadBalancer implements RSGroupableBalancer { @Override public void onConfigurationChange(Configuration conf) { + this.config = conf; boolean newFallbackEnabled = conf.getBoolean(FALLBACK_GROUP_ENABLE_KEY, false); if (fallbackEnabled != newFallbackEnabled) { LOG.info("Changing the value of {} from {} to {}", FALLBACK_GROUP_ENABLE_KEY, fallbackEnabled, newFallbackEnabled); fallbackEnabled = newFallbackEnabled; } + internalBalancer.onConfigurationChange(conf); } @Override