diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java index 321ad12..4e7d382 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java @@ -978,8 +978,15 @@ public class TestSplitTransactionOnCluster { List regionDirs = FSUtils.getRegionDirs(tableDir.getFileSystem(cluster.getConfiguration()), tableDir); assertEquals(3,regionDirs.size()); + cluster.startRegionServer(); + regionServer.kill(); + cluster.getRegionServerThreads().get(serverWith).join(); + // Wait until finish processing of shutdown + while (cluster.getMaster().getServerManager().areDeadServersInProgress()) { + Thread.sleep(5); + } + AssignmentManager am = cluster.getMaster().getAssignmentManager(); - am.processServerShutdown(regionServer.getServerName()); assertEquals(am.getRegionStates().getRegionsInTransition().toString(), 0, am .getRegionStates().getRegionsInTransition().size()); regionDirs =