commit 73a82bd7c62fb599ee25eb6185c03bb48dd45791
author Duo Zhang <zhangduo@apache.org> Fri Apr 30 22:45:33 2021 +0800
committer GitHub <noreply@github.com> Fri Apr 30 22:45:33 2021 +0800
tree 05f879e2b413076001bcdf5e686eb570c653ac48
parent 6c65314cdfe3ef1b128e45d2142720a42196cb7f

HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange should chain the request to internal balancer (#3209)

Signed-off-by: Yulin Niu <niuyulin@apache.org>

hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java
index 4c7c5dd..bedc776 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java
@@ -409,12 +409,14 @@
 
   @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