diff --git src/test/java/org/apache/hadoop/hbase/master/TestRestartCluster.java src/test/java/org/apache/hadoop/hbase/master/TestRestartCluster.java index cc08222..de3671e 100644 --- src/test/java/org/apache/hadoop/hbase/master/TestRestartCluster.java +++ src/test/java/org/apache/hadoop/hbase/master/TestRestartCluster.java @@ -22,7 +22,6 @@ package org.apache.hadoop.hbase.master; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; -import java.io.IOException; import java.util.List; import org.apache.commons.logging.Log; @@ -35,11 +34,11 @@ import org.apache.hadoop.hbase.TableExistsException; import org.apache.hadoop.hbase.client.MetaScanner; import org.apache.hadoop.hbase.executor.EventHandler.EventType; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.hbase.zookeeper.ZKAssign; import org.apache.hadoop.hbase.zookeeper.ZKUtil; import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher; import org.junit.After; -import org.junit.Before; import org.junit.Test; public class TestRestartCluster { @@ -92,6 +91,9 @@ public class TestRestartCluster { @Test (timeout=300000) public void testClusterRestart() throws Exception { UTIL.startMiniCluster(3); + while (!UTIL.getMiniHBaseCluster().getMaster().isInitialized()) { + Threads.sleep(1); + } LOG.info("\n\nCreating tables"); for(byte [] TABLE : TABLES) { UTIL.createTable(TABLE, FAMILY);