svn commit: r1484925 - /hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java

[stack]

Author: stack
Date: Tue May 21 20:02:50 2013
New Revision: 1484925

URL: http://svn.apache.org/r1484925
Log:
HBASE-8586 Revisit of hbase-8483, "HConnectionManager can leak ZooKeeper 
connections when using deleteStaleConnection"

Modified:
    
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java

Modified: 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java
URL: 
http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java?rev=1484925&r1=1484924&r2=1484925&view=diff
==============================================================================
--- 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java
 (original)
+++ 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java
 Tue May 21 20:02:50 2013
@@ -817,7 +817,7 @@ public class TestHCM {
     config.setInt("zookeeper.recovery.retry", 1);
     config.setInt("zookeeper.recovery.retry.intervalmill", 1000);
     config.setInt("hbase.rpc.timeout", 2000);
-    config.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 2);
+    config.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1);
 
     ThreadPoolExecutor pool = new ThreadPoolExecutor(1, 10,
       5, TimeUnit.SECONDS,
@@ -866,7 +866,7 @@ public class TestHCM {
               if 
(((ZooKeeperWatcher)watcher).getRecoverableZooKeeper().getState().isAlive()) {
                 // non-synchronized access to watcher; sleep and check again 
in case zk connection
                 // hasn't been cleaned up yet.
-                Thread.sleep(50);
+                Thread.sleep(1000);
                 if (((ZooKeeperWatcher) 
watcher).getRecoverableZooKeeper().getState().isAlive()) {
                   pool.shutdownNow();
                   fail("Live zookeeper in closed connection");