[hbase] branch branch-2 updated: HBASE-27270 Add bulkloadExecutor.resizeQueues (#4677)

[zhangduo]

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 c81517638cb HBASE-27270 Add bulkloadExecutor.resizeQueues (#4677)
c81517638cb is described below

commit c81517638cb021f1a30849b556a6a670a0c69926
Author: SiCheng-Zheng <643463...@qq.com>
AuthorDate: Mon Aug 8 18:14:49 2022 +0800

    HBASE-27270 Add bulkloadExecutor.resizeQueues (#4677)
    
    Co-authored-by: SiCheng-Zheng <zhengsich...@jd.com>
    Signed-off-by: Duo Zhang <zhang...@apache.org>
    (cherry picked from commit 4ebf71982c8a26033c0e7513ef4fc52a303ed71f)
---
 .../src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java         | 2 ++
 .../src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java  | 3 +++
 2 files changed, 5 insertions(+)

diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
index e00ca6a991c..4f95cccdff1 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
@@ -443,6 +443,8 @@ public abstract class RpcExecutor {
         configKey = RpcScheduler.IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH;
       } else if (name.toLowerCase(Locale.ROOT).contains("replication")) {
         configKey = RpcScheduler.IPC_SERVER_REPLICATION_MAX_CALLQUEUE_LENGTH;
+      } else if (name.toLowerCase(Locale.ROOT).contains("bulkLoad")) {
+        configKey = RpcScheduler.IPC_SERVER_BULKLOAD_MAX_CALLQUEUE_LENGTH;
       }
     }
     final int queueLimit = currentQueueLimit;
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
index ace61015ca6..c68c5f95bf2 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
@@ -157,6 +157,9 @@ public class SimpleRpcScheduler extends RpcScheduler 
implements ConfigurationObs
     if (metaTransitionExecutor != null) {
       metaTransitionExecutor.resizeQueues(conf);
     }
+    if (bulkloadExecutor != null) {
+      bulkloadExecutor.resizeQueues(conf);
+    }
 
     String callQueueType =
       conf.get(RpcExecutor.CALL_QUEUE_TYPE_CONF_KEY, 
RpcExecutor.CALL_QUEUE_TYPE_CONF_DEFAULT);