Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-27270 Add bulkloadExecutor.resizeQueues (#4677)

Browse Source 
Co-authored-by: SiCheng-Zheng <zhengsicheng@jd.com>
Signed-off-by: Duo Zhang <zhangduo@apache.org>
(cherry picked from commit 4ebf71982c8a26033c0e7513ef4fc52a303ed71f)
This commit is contained in:
SiCheng-Zheng 2022-08-08 18:14:49 +08:00 committed by Duo Zhang
parent 74726617b8
commit c81517638c
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
View File

@ -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;

3
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
View File

@ -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);