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

HBASE-13526 TestRegionServerReportForDuty can be flaky: hang or timeout

This commit is contained in:
Jerry He 2015-04-22 22:21:54 -07:00
parent 4666bf86a2
commit f1c29a8385
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerReportForDuty.java
View File

@ -91,6 +91,8 @@ public class TestRegionServerReportForDuty {
master.start();
rs.start();
waitForClusterOnline(master);
// Add a 2nd region server
cluster.getConfiguration().set(HConstants.REGION_SERVER_IMPL, MyRegionServer.class.getName());
rs2 = cluster.addRegionServer();
@ -100,7 +102,7 @@ public class TestRegionServerReportForDuty {
LOG.debug("Starting 2nd region server: " + rs2.getRegionServer().getServerName());
rs2.start();
waitForClusterOnline(master);
waitForSecondRsStarted();
// Stop the current master.
master.getMaster().stop("Stopping master");
@ -125,8 +127,7 @@ public class TestRegionServerReportForDuty {
private void waitForClusterOnline(MasterThread master) throws InterruptedException {
while (true) {
if (master.getMaster().isInitialized()
&& ((MyRegionServer) rs2.getRegionServer()).getRpcStubCreatedFlag() == true) {
if (master.getMaster().isInitialized()) {
break;
}
Thread.sleep(SLEEP_INTERVAL);
@ -135,6 +136,16 @@ public class TestRegionServerReportForDuty {
rs.waitForServerOnline();
}
private void waitForSecondRsStarted() throws InterruptedException {
while (true) {
if (((MyRegionServer) rs2.getRegionServer()).getRpcStubCreatedFlag() == true) {
break;
}
Thread.sleep(SLEEP_INTERVAL);
LOG.debug("Waiting 2nd RS to be started ...");
}
}
// Create a Region Server that provide a hook so that we can wait for the master switch over
// before continuing reportForDuty to the mater.
// The idea is that we get a RPC connection to the first active master, then we wait.
@ -169,6 +180,7 @@ public class TestRegionServerReportForDuty {
try {
Thread.sleep(SLEEP_INTERVAL);
} catch (InterruptedException e) {
return null;
}
LOG.debug("Waiting for master switch over ... ");
}