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

HBASE-14433 Set down the client executor core thread count from 256 to number of processors

Browse Source
This commit is contained in:
stack 2015-09-15 22:36:05 -07:00
parent 27a993d837
commit d2e3381818
3 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
View File

@ -370,7 +370,9 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
synchronized (this) { synchronized (this) {
if (batchPool == null) { if (batchPool == null) {
this.batchPool = getThreadPool(conf.getInt("hbase.hconnection.threads.max", 256), this.batchPool = getThreadPool(conf.getInt("hbase.hconnection.threads.max", 256),
conf.getInt("hbase.hconnection.threads.core", 256), "-shared-", null); conf.getInt("hbase.hconnection.threads.core",
Runtime.getRuntime().availableProcessors()),
"-shared-", null);
this.cleanupPool = true; this.cleanupPool = true;
} }
} }
@ -385,7 +387,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
maxThreads = Runtime.getRuntime().availableProcessors() * 8; maxThreads = Runtime.getRuntime().availableProcessors() * 8;
} }
if (coreThreads == 0) { if (coreThreads == 0) {
coreThreads = Runtime.getRuntime().availableProcessors() * 8; coreThreads = Runtime.getRuntime().availableProcessors();
} }
long keepAliveTime = conf.getLong("hbase.hconnection.threads.keepalivetime", 60); long keepAliveTime = conf.getLong("hbase.hconnection.threads.keepalivetime", 60);
BlockingQueue<Runnable> workQueue = passedWorkQueue; BlockingQueue<Runnable> workQueue = passedWorkQueue;

8
hbase-client/src/test/resources/hbase-site.xml
View File

@ -25,4 +25,12 @@
<name>hbase.defaults.for.version.skip</name> <name>hbase.defaults.for.version.skip</name>
<value>true</value> <value>true</value>
</property> </property>
<property>
<name>hbase.hconnection.meta.lookup.threads.core</name>
<value>4</value>
</property>
<property>
<name>hbase.hconnection.threads.keepalivetime</name>
<value>3</value>
</property>
</configuration> </configuration>

8
hbase-server/src/test/resources/hbase-site.xml
View File

@ -162,4 +162,12 @@
Enable replay sanity checks on procedure tests. Enable replay sanity checks on procedure tests.
</description> </description>
</property> </property>
<property>
<name>hbase.hconnection.meta.lookup.threads.core</name>
<value>4</value>
</property>
<property>
<name>hbase.hconnection.threads.keepalivetime</name>
<value>3</value>
</property>
</configuration> </configuration>