diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java index 0e8a03fa79f..2262a0f29d4 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java @@ -370,9 +370,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable { synchronized (this) { if (batchPool == null) { this.batchPool = getThreadPool(conf.getInt("hbase.hconnection.threads.max", 256), - conf.getInt("hbase.hconnection.threads.core", - Runtime.getRuntime().availableProcessors()), - "-shared-", null); + conf.getInt("hbase.hconnection.threads.core", 256), "-shared-", null); this.cleanupPool = true; } } @@ -387,7 +385,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable { maxThreads = Runtime.getRuntime().availableProcessors() * 8; } if (coreThreads == 0) { - coreThreads = Runtime.getRuntime().availableProcessors(); + coreThreads = Runtime.getRuntime().availableProcessors() * 8; } long keepAliveTime = conf.getLong("hbase.hconnection.threads.keepalivetime", 60); BlockingQueue workQueue = passedWorkQueue; diff --git a/hbase-client/src/test/resources/hbase-site.xml b/hbase-client/src/test/resources/hbase-site.xml index 57882380451..ab4d1cd0b73 100644 --- a/hbase-client/src/test/resources/hbase-site.xml +++ b/hbase-client/src/test/resources/hbase-site.xml @@ -25,12 +25,4 @@ hbase.defaults.for.version.skip true - - hbase.hconnection.meta.lookup.threads.core - 4 - - - hbase.hconnection.threads.keepalivetime - 3 - diff --git a/hbase-server/src/test/resources/hbase-site.xml b/hbase-server/src/test/resources/hbase-site.xml index 1ae5435669b..2d06c0acf5d 100644 --- a/hbase-server/src/test/resources/hbase-site.xml +++ b/hbase-server/src/test/resources/hbase-site.xml @@ -162,12 +162,4 @@ Enable replay sanity checks on procedure tests. - - hbase.hconnection.meta.lookup.threads.core - 4 - - - hbase.hconnection.threads.keepalivetime - 3 -