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

HBASE-14884 TestSplitTransactionOnCluster.testSSHCleanupDaugtherRegionsOfAbortedSplit is flakey

This commit is contained in:
chenheng 2015-11-27 11:24:15 +08:00
parent 0d72849581
commit b280a41ba6
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java
View File

@ -972,20 +972,21 @@ public class TestSplitTransactionOnCluster {
List<HRegion> regions = cluster.getRegions(desc.getTableName()); List<HRegion> regions = cluster.getRegions(desc.getTableName());
int serverWith = cluster.getServerWith(regions.get(0).getRegionInfo().getRegionName()); int serverWith = cluster.getServerWith(regions.get(0).getRegionInfo().getRegionName());
HRegionServer regionServer = cluster.getRegionServer(serverWith); HRegionServer regionServer = cluster.getRegionServer(serverWith);
cluster.getServerWith(regions.get(0).getRegionInfo().getRegionName());
SplitTransactionImpl st = new SplitTransactionImpl(regions.get(0), Bytes.toBytes("r3")); SplitTransactionImpl st = new SplitTransactionImpl(regions.get(0), Bytes.toBytes("r3"));
st.prepare(); st.prepare();
st.stepsBeforePONR(regionServer, regionServer, false); st.stepsBeforePONR(regionServer, regionServer, false);
Path tableDir = Path tableDir =
FSUtils.getTableDir(cluster.getMaster().getMasterFileSystem().getRootDir(), FSUtils.getTableDir(cluster.getMaster().getMasterFileSystem().getRootDir(),
desc.getTableName()); desc.getTableName());
tableDir.getFileSystem(cluster.getConfiguration());
List<Path> regionDirs = List<Path> regionDirs =
FSUtils.getRegionDirs(tableDir.getFileSystem(cluster.getConfiguration()), tableDir); FSUtils.getRegionDirs(tableDir.getFileSystem(cluster.getConfiguration()), tableDir);
assertEquals(3,regionDirs.size()); assertEquals(3,regionDirs.size());
cluster.startRegionServer();
regionServer.kill(); regionServer.kill();
cluster.getRegionServerThreads().get(serverWith).join(); // Before we check deadServerInProgress, we should ensure server is dead at master side.
while (!cluster.getMaster().getServerManager().
getDeadServers().isDeadServer(regionServer.serverName)) {
Thread.sleep(10);
}
// Wait until finish processing of shutdown // Wait until finish processing of shutdown
while (cluster.getMaster().getServerManager().areDeadServersInProgress()) { while (cluster.getMaster().getServerManager().areDeadServersInProgress()) {
Thread.sleep(10); Thread.sleep(10);