Index: hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java =================================================================== --- hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java (revision 1565490) +++ hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java (working copy) @@ -207,6 +207,7 @@ } private void putAndReplicateRows() throws Exception { + LOG.debug("putAndReplicateRows"); // add rows to Master cluster, Put p; @@ -260,6 +261,7 @@ } private void mimicSyncUpAfterDelete() throws Exception { + LOG.debug("mimicSyncUpAfterDelete"); utility2.shutdownMiniHBaseCluster(); List list = new ArrayList(); @@ -329,6 +331,7 @@ } private void mimicSyncUpAfterPut() throws Exception { + LOG.debug("mimicSyncUpAfterPut"); utility1.restartHBaseCluster(1); utility2.shutdownMiniHBaseCluster(); Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java (revision 1565490) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java (working copy) @@ -115,6 +115,7 @@ } manager.join(); + zkw.close(); return (0); }