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 df0d87c..67c942b 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 @@ -1325,7 +1325,7 @@ public class TestSplitTransactionOnCluster { assertNotNull(observer); observer.latch.await(); observer.postSplit.await(); - LOG.info("Waiting for region to come out of RIT"); + LOG.info("Waiting for region to come out of RIT: " + actualRegion); TESTING_UTIL.waitFor(60000, 1000, new Waiter.Predicate() { @Override public boolean evaluate() throws Exception { @@ -1336,7 +1336,9 @@ public class TestSplitTransactionOnCluster { }); regions = TESTING_UTIL.getHBaseAdmin().getTableRegions(tableName); assertTrue(regions.size() == 1); - assertTrue(admin.balancer()); + RegionStates regionStates = cluster.getMaster().getAssignmentManager().getRegionStates(); + Map rit = regionStates.getRegionsInTransition(); + assertTrue(rit.size() == 0); } finally { table.close(); connection.close();