HBASE-20042 TestRegionServerAbort flakey
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3f82098d Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3f82098d Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3f82098d Branch: refs/heads/HBASE-19064 Commit: 3f82098d4b7ae595aa6702d3fb7cc2fac682691b Parents: 173a5bf Author: Michael Stack <st...@apache.org> Authored: Wed Feb 21 13:24:32 2018 -0800 Committer: Michael Stack <st...@apache.org> Committed: Wed Feb 21 13:26:10 2018 -0800 ---------------------------------------------------------------------- .../hbase/regionserver/TestRegionServerAbort.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/3f82098d/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java index fdb6887..0c778fb 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java @@ -22,6 +22,7 @@ import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; import java.io.IOException; +import java.util.List; import java.util.Optional; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; @@ -52,6 +53,7 @@ import org.apache.hadoop.hbase.testclassification.MediumTests; import org.apache.hadoop.hbase.testclassification.RegionServerTests; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.JVMClusterUtil; +import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.hbase.wal.WAL; import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.hdfs.DFSConfigKeys; @@ -146,6 +148,16 @@ public class TestRegionServerAbort { // should have triggered an abort due to FileNotFoundException // verify that the regionserver is stopped + List<HRegion> regions = null; + do { + regions = cluster.findRegionsForTable(tableName); + if (regions != null && regions.size() > 0) { + break; + } + LOG.warn("Waiting on regions for {} to online"); + Threads.sleep(100); + } while(true); + HRegion firstRegion = cluster.findRegionsForTable(tableName).get(0); assertNotNull(firstRegion); assertNotNull(firstRegion.getRegionServerServices());
