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

HBASE-10482 ReplicationSyncUp doesn't clean up its ZK, needed for tests 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1565837 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2014-02-07 22:26:45 +00:00
parent 5102eed4d8
commit 653e682d99
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.java
View File

@ -115,6 +115,7 @@ public class ReplicationSyncUp extends Configured implements Tool {
} }
manager.join(); manager.join();
zkw.close();
return (0); return (0);
} }

3
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSyncUpTool.java
View File

@ -207,6 +207,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
} }
private void putAndReplicateRows() throws Exception { private void putAndReplicateRows() throws Exception {
LOG.debug("putAndReplicateRows");
// add rows to Master cluster, // add rows to Master cluster,
Put p; Put p;
@ -260,6 +261,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
} }
private void mimicSyncUpAfterDelete() throws Exception { private void mimicSyncUpAfterDelete() throws Exception {
LOG.debug("mimicSyncUpAfterDelete");
utility2.shutdownMiniHBaseCluster(); utility2.shutdownMiniHBaseCluster();
List<Delete> list = new ArrayList<Delete>(); List<Delete> list = new ArrayList<Delete>();
@ -329,6 +331,7 @@ public class TestReplicationSyncUpTool extends TestReplicationBase {
} }
private void mimicSyncUpAfterPut() throws Exception { private void mimicSyncUpAfterPut() throws Exception {
LOG.debug("mimicSyncUpAfterPut");
utility1.restartHBaseCluster(1); utility1.restartHBaseCluster(1);
utility2.shutdownMiniHBaseCluster(); utility2.shutdownMiniHBaseCluster();