Revert "HBASE-14433 Set down the client executor core thread count from 256 to number of processors"
This reverts commit d2e3381818
.
This commit is contained in:
parent
d2e3381818
commit
8633b26ee5
|
@ -370,9 +370,7 @@ 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",
|
conf.getInt("hbase.hconnection.threads.core", 256), "-shared-", null);
|
||||||
Runtime.getRuntime().availableProcessors()),
|
|
||||||
"-shared-", null);
|
|
||||||
this.cleanupPool = true;
|
this.cleanupPool = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -387,7 +385,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();
|
coreThreads = Runtime.getRuntime().availableProcessors() * 8;
|
||||||
}
|
}
|
||||||
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;
|
||||||
|
|
|
@ -25,12 +25,4 @@
|
||||||
<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>
|
||||||
|
|
|
@ -162,12 +162,4 @@
|
||||||
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>
|
||||||
|
|
Loading…
Reference in New Issue