HBASE-27325 the bulkload max call queue size can be update to a wrong value (#4728)
Co-authored-by: huiruan <huiruan@tencent.com> Signed-off-by: Wellington Chevreuil <wchevreuil@apache.org> Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
parent
b44bfc52cc
commit
92cf962fee
|
@ -443,7 +443,7 @@ public abstract class RpcExecutor {
|
||||||
configKey = RpcScheduler.IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH;
|
configKey = RpcScheduler.IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH;
|
||||||
} else if (name.toLowerCase(Locale.ROOT).contains("replication")) {
|
} else if (name.toLowerCase(Locale.ROOT).contains("replication")) {
|
||||||
configKey = RpcScheduler.IPC_SERVER_REPLICATION_MAX_CALLQUEUE_LENGTH;
|
configKey = RpcScheduler.IPC_SERVER_REPLICATION_MAX_CALLQUEUE_LENGTH;
|
||||||
} else if (name.toLowerCase(Locale.ROOT).contains("bulkLoad")) {
|
} else if (name.toLowerCase(Locale.ROOT).contains("bulkload")) {
|
||||||
configKey = RpcScheduler.IPC_SERVER_BULKLOAD_MAX_CALLQUEUE_LENGTH;
|
configKey = RpcScheduler.IPC_SERVER_BULKLOAD_MAX_CALLQUEUE_LENGTH;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue