diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java index 259b6654ba2..9688ad3fbd0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java @@ -68,7 +68,7 @@ class ZKAsyncRegistry implements AsyncRegistry { ZKAsyncRegistry(Configuration conf) { this.znodePaths = new ZNodePaths(conf); int zkSessionTimeout = conf.getInt(ZK_SESSION_TIMEOUT, DEFAULT_ZK_SESSION_TIMEOUT); - int zkRetry = conf.getInt("zookeeper.recovery.retry", 3); + int zkRetry = conf.getInt("zookeeper.recovery.retry", 30); int zkRetryIntervalMs = conf.getInt("zookeeper.recovery.retry.intervalmill", 1000); this.zk = CuratorFrameworkFactory.builder() .connectString(ZKConfig.getZKQuorumServersString(conf)).sessionTimeoutMs(zkSessionTimeout)