From accb4ff4d20d8a2e4432becd4aa98ddd87dfbfc0 Mon Sep 17 00:00:00 2001 From: dvdreddy Date: Tue, 18 Oct 2016 16:38:31 -0700 Subject: [PATCH] HBASE-16878 Account increased call queues for the maxCallQueueLength Change-Id: I710347f13c7edc13623c637effccd7dfe5376bda --- .../src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java | 2 ++ 1 file changed, 2 insertions(+) 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 3ea2887..406d0af 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 @@ -195,6 +195,8 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs float callQueuesHandlersFactor = conf.getFloat(CALL_QUEUE_HANDLER_FACTOR_CONF_KEY, 0); int numCallQueues = Math.max(1, (int)Math.round(handlerCount * callQueuesHandlersFactor)); + // Offset maxQueueLength to account for the increased callQueues + maxQueueLength /= numCallQueues; LOG.info("Using " + callQueueType + " as user call queue; numCallQueues=" + numCallQueues + "; callQReadShare=" + callqReadShare + ", callQScanShare=" + callqScanShare); if (numCallQueues > 1 && callqReadShare > 0) { -- 2.2.1