HBASE-9670 Client pause should be 100ms everywhere

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1527537 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
nkeywal 2013-09-30 13:05:39 +00:00
parent 266e1791d1
commit c3bfc4ef85
3 changed files with 5 additions and 3 deletions

View File

@ -190,7 +190,8 @@ public class HBaseAdmin implements Abortable, Closeable {
this.conf = connection.getConfiguration();
this.connection = connection;
this.pause = this.conf.getLong("hbase.client.pause", 1000);
this.pause = this.conf.getLong(HConstants.HBASE_CLIENT_PAUSE,
HConstants.DEFAULT_HBASE_CLIENT_PAUSE);
this.numRetries = this.conf.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER,
HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER);
this.retryLongerMultiplier = this.conf.getInt(

View File

@ -1233,7 +1233,8 @@ public class RpcClient {
RpcClient(Configuration conf, String clusterId, SocketFactory factory, SocketAddress localAddr) {
this.maxIdleTime = conf.getInt("hbase.ipc.client.connection.maxidletime", 10000); //10s
this.maxRetries = conf.getInt("hbase.ipc.client.connect.max.retries", 0);
this.failureSleep = conf.getInt("hbase.client.pause", 1000);
this.failureSleep = conf.getLong(HConstants.HBASE_CLIENT_PAUSE,
HConstants.DEFAULT_HBASE_CLIENT_PAUSE);
this.tcpNoDelay = conf.getBoolean("hbase.ipc.client.tcpnodelay", true);
this.tcpKeepAlive = conf.getBoolean("hbase.ipc.client.tcpkeepalive", true);
this.pingInterval = getPingInterval(conf);

View File

@ -570,7 +570,7 @@ public final class HConstants {
/**
* Default value of {@link #HBASE_CLIENT_PAUSE}.
*/
public static long DEFAULT_HBASE_CLIENT_PAUSE = 1000;
public static long DEFAULT_HBASE_CLIENT_PAUSE = 100;
/**
* Parameter name for server pause value, used mostly as value to wait before