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:25:37 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 350904e90 -> d08bafad1


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/d08bafad
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d08bafad
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d08bafad

Branch: refs/heads/master
Commit: d08bafad1a5a9bd52e494a00fe7434a90a906b33
Parents: 350904e
Author: ChiaPing Tsai <chia7712@gmail.com>
Authored: Sat Feb 18 21:29:53 2017 +0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Sun Feb 19 13:25:32 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/d08bafad/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 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);


Mime
View raw message