Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16341 Missing bit on "Regression: Random Read/WorkloadC slower in 1.x than 0.98"

This commit is contained in:
stack 2016-08-13 20:16:44 -07:00
parent cf9878f77e
commit 6976a7b312
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
View File

@ -96,9 +96,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs
replicationExecutor.resizeQueues(conf); replicationExecutor.resizeQueues(conf);
} }
String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_CONF_DEFAULT);
CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE);
if (isCodelQueueType(callQueueType)) { if (isCodelQueueType(callQueueType)) {
// update CoDel Scheduler tunables // update CoDel Scheduler tunables
int codelTargetDelay = conf.getInt(CALL_QUEUE_CODEL_TARGET_DELAY, int codelTargetDelay = conf.getInt(CALL_QUEUE_CODEL_TARGET_DELAY,
@ -184,8 +182,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs
this.highPriorityLevel = highPriorityLevel; this.highPriorityLevel = highPriorityLevel;
this.abortable = server; this.abortable = server;
String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, String callQueueType = conf.get(CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_CONF_DEFAULT);
CALL_QUEUE_TYPE_FIFO_CONF_VALUE);
float callqReadShare = conf.getFloat(CALL_QUEUE_READ_SHARE_CONF_KEY, 0); float callqReadShare = conf.getFloat(CALL_QUEUE_READ_SHARE_CONF_KEY, 0);
float callqScanShare = conf.getFloat(CALL_QUEUE_SCAN_SHARE_CONF_KEY, 0); float callqScanShare = conf.getFloat(CALL_QUEUE_SCAN_SHARE_CONF_KEY, 0);