From 2e18d1b7889c48f78a3b048e578d2985eec3b4e5 Mon Sep 17 00:00:00 2001 From: ChiaPing Tsai Date: Sat, 18 Feb 2017 21:29:53 +0800 Subject: [PATCH] HBASE-17661 fix the queue length passed to FastPathBalancedQueueRpcExecutor --- .../src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 1f7e8ba..616f741 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 @@ -87,7 +87,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs } else { if (RpcExecutor.isFifoQueueType(callQueueType)) { callExecutor = new FastPathBalancedQueueRpcExecutor("deafult.FPBQ", handlerCount, - maxPriorityQueueLength, priority, conf, server); + maxQueueLength, priority, conf, server); } else { callExecutor = new BalancedQueueRpcExecutor("deafult.BQ", handlerCount, maxQueueLength, priority, conf, server); -- 2.10.1 (Apple Git-78)