Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20042 TestRegionServerAbort flakey

This commit is contained in:
Michael Stack 2018-02-21 13:24:32 -08:00
parent 67b7ce38fb
commit baec532aa2
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java
View File

@ -22,6 +22,7 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import java.io.IOException; import java.io.IOException;
import java.util.List;
import java.util.Optional; import java.util.Optional;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem; 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.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.JVMClusterUtil; 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.WAL;
import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.hbase.wal.WALEdit;
import org.apache.hadoop.hdfs.DFSConfigKeys; import org.apache.hadoop.hdfs.DFSConfigKeys;
@ -146,6 +148,16 @@ public class TestRegionServerAbort {
// should have triggered an abort due to FileNotFoundException // should have triggered an abort due to FileNotFoundException
// verify that the regionserver is stopped // 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); HRegion firstRegion = cluster.findRegionsForTable(tableName).get(0);
assertNotNull(firstRegion); assertNotNull(firstRegion);
assertNotNull(firstRegion.getRegionServerServices()); assertNotNull(firstRegion.getRegionServerServices());