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

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


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

commit 3ebcfda3c7be97324c1c306820a196080bce152a
Author: Duo Zhang <[email protected]>
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 <[email protected]>
---
 .../java/org/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 901aafa..0fd5224 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

Reply via email to