HBASE-16341 Missing bit on "Regression: Random Read/WorkloadC slower in 1.x than 0.98"
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/907ac1f6 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/907ac1f6 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/907ac1f6 Branch: refs/heads/hbase-12439 Commit: 907ac1f6552e9e1cd7e33adeaf51fda2f3f19734 Parents: 65c03b0 Author: stack <[email protected]> Authored: Sat Aug 13 20:16:44 2016 -0700 Committer: stack <[email protected]> Committed: Sat Aug 13 20:16:44 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/907ac1f6/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 082c743..3ea2887 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 @@ -96,9 +96,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs replicationExecutor.resizeQueues(conf); } - String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, - CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE); - + String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_CONF_DEFAULT); if (isCodelQueueType(callQueueType)) { // update CoDel Scheduler tunables int codelTargetDelay = conf.getInt(CALL_QUEUE_CODEL_TARGET_DELAY, @@ -184,8 +182,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs this.highPriorityLevel = highPriorityLevel; this.abortable = server; - String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, - CALL_QUEUE_TYPE_FIFO_CONF_VALUE); + String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_CONF_DEFAULT); float callqReadShare = conf.getFloat(CALL_QUEUE_READ_SHARE_CONF_KEY, 0); float callqScanShare = conf.getFloat(CALL_QUEUE_SCAN_SHARE_CONF_KEY, 0);
