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

HBASE-3863 Fix failing TestHBaseFsck.testHBaseFsckMeta unit test 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1100427 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2011-05-07 01:32:34 +00:00
parent 7d03a7dbb6
commit 3b993d8c4d
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/test/java/org/apache/hadoop/hbase/TestZooKeeper.java
View File

@ -100,9 +100,13 @@ public class TestZooKeeper {
HConnection connection = HConnectionManager.getConnection(c);
ZooKeeperWatcher connectionZK = connection.getZooKeeperWatcher();
long sessionID = connectionZK.getZooKeeper().getSessionId();
byte[] password = connectionZK.getZooKeeper().getSessionPasswd();
byte [] password = connectionZK.getZooKeeper().getSessionPasswd();
ZooKeeper zk = new ZooKeeper(quorumServers, sessionTimeout,
EmptyWatcher.instance, sessionID, password);
LOG.info("Session timeout=" + zk.getSessionTimeout() +
", original=" + sessionTimeout +
", id=" + zk.getSessionId());
zk.close();
Thread.sleep(sessionTimeout * 3L);
@ -110,11 +114,11 @@ public class TestZooKeeper {
// provoke session expiration by doing something with ZK
ZKUtil.dump(connectionZK);
// Check that the old ZK conenction is closed, means we did expire
// Check that the old ZK connection is closed, means we did expire
System.err.println("ZooKeeper should have timed out");
LOG.info("state=" + connectionZK.getZooKeeper().getState());
Assert.assertTrue(connectionZK.getZooKeeper().getState().equals(
States.CLOSED));
String state = connectionZK.getZooKeeper().getState().toString();
Assert.assertTrue("State=" + state,
connectionZK.getZooKeeper().getState().equals(States.CLOSED));
// Check that the client recovered
ZooKeeperWatcher newConnectionZK = connection.getZooKeeperWatcher();