diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java
index 52b27738492..59b7f0776b7 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java
@@ -115,6 +115,7 @@ public class ReplicationSyncUp extends Configured implements Tool {
     }
 
     manager.join();
+    zkw.close();
 
     return (0);
   }
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java
index 817111a356f..e8620d47543 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java
@@ -207,6 +207,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
   }
 
   private void putAndReplicateRows() throws Exception {
+    LOG.debug("putAndReplicateRows");
     // add rows to Master cluster,
     Put p;
 
@@ -260,6 +261,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
   }
 
   private void mimicSyncUpAfterDelete() throws Exception {
+    LOG.debug("mimicSyncUpAfterDelete");
     utility2.shutdownMiniHBaseCluster();
 
     List<Delete> list = new ArrayList<Delete>();
@@ -329,6 +331,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
   }
 
   private void mimicSyncUpAfterPut() throws Exception {
+    LOG.debug("mimicSyncUpAfterPut");
     utility1.restartHBaseCluster(1);
     utility2.shutdownMiniHBaseCluster();