HBASE-19446 Misspelled 'default' in SimpleRpcScheduler
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5398d83b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5398d83b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5398d83b Branch: refs/heads/branch-1 Commit: 5398d83bc71e41752a116f02e935b9f8f8fc198d Parents: 70c7688 Author: Andrew Purtell <apurt...@apache.org> Authored: Wed Dec 6 17:11:10 2017 -0800 Committer: Andrew Purtell <apurt...@apache.org> Committed: Wed Dec 6 17:11:15 2017 -0800 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java | 6 +++--- .../org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/5398d83b/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 698381c..8fc0023 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 @@ -82,14 +82,14 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs if (callqReadShare > 0) { // at least 1 read handler and 1 write handler - callExecutor = new RWQueueRpcExecutor("deafult.RWQ", Math.max(2, handlerCount), + callExecutor = new RWQueueRpcExecutor("default.RWQ", Math.max(2, handlerCount), maxQueueLength, priority, conf, server); } else { if (RpcExecutor.isFifoQueueType(callQueueType) || RpcExecutor.isCodelQueueType(callQueueType)) { - callExecutor = new FastPathBalancedQueueRpcExecutor("deafult.FPBQ", handlerCount, + callExecutor = new FastPathBalancedQueueRpcExecutor("default.FPBQ", handlerCount, maxQueueLength, priority, conf, server); } else { - callExecutor = new BalancedQueueRpcExecutor("deafult.BQ", handlerCount, maxQueueLength, + callExecutor = new BalancedQueueRpcExecutor("default.BQ", handlerCount, maxQueueLength, priority, conf, server); } } http://git-wip-us.apache.org/repos/asf/hbase/blob/5398d83b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java index 2fd203c..8ae1a2f 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java @@ -410,7 +410,7 @@ public class TestSimpleRpcScheduler { @Test public void testCoDelScheduling() throws Exception { CoDelEnvironmentEdge envEdge = new CoDelEnvironmentEdge(); - envEdge.threadNamePrefixs.add("RpcServer.deafult.FPBQ.Codel.handler"); + envEdge.threadNamePrefixs.add("RpcServer.default.FPBQ.Codel.handler"); Configuration schedConf = HBaseConfiguration.create(); schedConf.setInt(RpcScheduler.IPC_SERVER_MAX_CALLQUEUE_LENGTH, 250);
