hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-17661 fix the queue length passed to FastPathBalancedQueueRpcExecutor
Date Sun, 19 Feb 2017 21:26:30 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 6b96b0ce8 -> 964e17f7b


HBASE-17661 fix the queue length passed to FastPathBalancedQueueRpcExecutor

Signed-off-by: tedyu <yuzhihong@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/964e17f7
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/964e17f7
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/964e17f7

Branch: refs/heads/branch-1
Commit: 964e17f7b002645bb840c9a5f94802763eda87c4
Parents: 6b96b0c
Author: ChiaPing Tsai <chia7712@gmail.com>
Authored: Sat Feb 18 19:13:47 2017 +0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Sun Feb 19 13:26:24 2017 -0800

----------------------------------------------------------------------
 .../main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/964e17f7/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
----------------------------------------------------------------------
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 683346a..28b308f 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);


Mime
View raw message