HBASE-20042 TestRegionServerAbort flakey; ADDENDUM, RETRY
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/13223c21 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/13223c21 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/13223c21 Branch: refs/heads/HBASE-19064 Commit: 13223c217ca6cb84a96f3c70b8c38ec19eca729f Parents: 61b5516 Author: Michael Stack <st...@apache.org> Authored: Wed Feb 21 15:26:21 2018 -0800 Committer: Michael Stack <st...@apache.org> Committed: Wed Feb 21 15:26:21 2018 -0800 ---------------------------------------------------------------------- .../hbase/regionserver/TestRegionServerAbort.java | 17 +++-------------- 1 file changed, 3 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/13223c21/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 0c778fb..d5cbad0 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 @@ -144,21 +144,10 @@ public class TestRegionServerAbort { put.addColumn(FAMILY_BYTES, Bytes.toBytes("c"), new byte[]{}); put.setAttribute(StopBlockingRegionObserver.DO_ABORT, new byte[]{1}); - table.put(put); - // 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); - + List<HRegion> regions = cluster.findRegionsForTable(tableName); HRegion firstRegion = cluster.findRegionsForTable(tableName).get(0); + table.put(put); + // Verify that the regionserver is stopped assertNotNull(firstRegion); assertNotNull(firstRegion.getRegionServerServices()); LOG.info("isAborted = " + firstRegion.getRegionServerServices().isAborted());