diff --git a/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java b/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java index 51bd6fa..8ad298d 100644 --- a/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java +++ b/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java @@ -53,6 +53,7 @@ public class TestReplicationPeer { LOG.info("Expiring ReplicationPeer ZooKeeper session."); utility.expireSession(zkw, null, false); + zkw.getRecoverableZooKeeper().getZooKeeper().close(); try { LOG.info("Attempting to use expired ReplicationPeer ZooKeeper session.");