diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java index fe3ecc0..2806156 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java @@ -66,16 +66,13 @@ public class SimpleRpcScheduler extends RpcScheduler { PriorityFunction priority, int highPriorityLevel) { int maxQueueLength = conf.getInt(CALL_QUEUE_MAX_LENGTH_CONF_KEY, - conf.getInt("ipc.server.max.callqueue.length", - handlerCount * RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER)); + handlerCount * RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER); this.priority = priority; this.highPriorityLevel = highPriorityLevel; - float callqReadShare = conf.getFloat(CALL_QUEUE_READ_SHARE_CONF_KEY, - conf.getFloat("ipc.server.callqueue.read.share", 0)); + float callqReadShare = conf.getFloat(CALL_QUEUE_READ_SHARE_CONF_KEY, 0); - float callQueuesHandlersFactor = conf.getFloat(CALL_QUEUE_HANDLER_FACTOR_CONF_KEY, - conf.getFloat("ipc.server.callqueue.handler.factor", 0)); + float callQueuesHandlersFactor = conf.getFloat(CALL_QUEUE_HANDLER_FACTOR_CONF_KEY, 0); int numCallQueues = Math.max(1, (int)Math.round(handlerCount * callQueuesHandlersFactor)); LOG.info("Using default user call queue, count=" + numCallQueues);