[hbase] branch master updated: HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange should chain the request to internal balancer (#3209)

[zhangduo]

This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new 73a82bd  HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange 
should chain the request to internal balancer (#3209)
73a82bd is described below

commit 73a82bd7c62fb599ee25eb6185c03bb48dd45791
Author: Duo Zhang <zhang...@apache.org>
AuthorDate: Fri Apr 30 22:45:33 2021 +0800

    HBASE-25825 RSGroupBasedLoadBalancer.onConfigurationChange should chain the 
request to internal balancer (#3209)
    
    Signed-off-by: Yulin Niu <niuyu...@apache.org>
---
 .../java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java  | 2 ++
 1 file changed, 2 insertions(+)

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 @@ public class RSGroupBasedLoadBalancer implements 
LoadBalancer {
 
   @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