HBASE-27270 Add bulkloadExecutor.resizeQueues (#4677)
Co-authored-by: SiCheng-Zheng <zhengsicheng@jd.com> Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
parent
f8dcf07055
commit
4ebf71982c
|
@ -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;
|
||||
|
|
|
@ -156,6 +156,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);
|
||||
|
|
Loading…
Reference in New Issue