HBASE-22472 The newly split TestReplicationStatus* tests are flaky

This commit is contained in:
Duo Zhang 2019-05-30 15:55:37 +08:00 committed by zhangduo
parent 1a2632b796
commit e4057c5555
5 changed files with 6 additions and 6 deletions

View File

@ -45,7 +45,7 @@ public class TestReplicationStatusAfterLagging extends TestReplicationBase {
@Test
public void testReplicationStatusAfterLagging() throws Exception {
utility2.shutdownMiniHBaseCluster();
restartHBaseCluster(utility1, NUM_SLAVES1);
restartHBaseCluster(utility1, 1);
// add some values to cluster 1
for (int i = 0; i < NB_ROWS_IN_BATCH; i++) {
Put p = new Put(Bytes.toBytes("row" + i));

View File

@ -52,7 +52,7 @@ public class TestReplicationStatusBothNormalAndRecoveryLagging extends TestRepli
htable1.put(p);
}
Thread.sleep(10000);
restartHBaseCluster(utility1, NUM_SLAVES1);
restartHBaseCluster(utility1, 1);
Admin hbaseAdmin = utility1.getAdmin();
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
Thread.sleep(10000);

View File

@ -46,7 +46,7 @@ public class TestReplicationStatusSourceStartedTargetStoppedNewOp extends TestRe
@Test
public void testReplicationStatusSourceStartedTargetStoppedNewOp() throws Exception {
utility2.shutdownMiniHBaseCluster();
restartHBaseCluster(utility1, NUM_SLAVES1);
restartHBaseCluster(utility1, 1);
Admin hbaseAdmin = utility1.getAdmin();
// add some values to source cluster
for (int i = 0; i < NB_ROWS_IN_BATCH; i++) {

View File

@ -41,9 +41,9 @@ public class TestReplicationStatusSourceStartedTargetStoppedNoOps extends TestRe
HBaseClassTestRule.forClass(TestReplicationStatusSourceStartedTargetStoppedNoOps.class);
@Test
public void c() throws Exception {
public void testReplicationStatusSourceStartedTargetStoppedNoOps() throws Exception {
utility2.shutdownMiniHBaseCluster();
restartHBaseCluster(utility1, NUM_SLAVES1);
restartHBaseCluster(utility1, 1);
Admin hbaseAdmin = utility1.getAdmin();
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
Thread.sleep(10000);

View File

@ -54,7 +54,7 @@ public class TestReplicationStatusSourceStartedTargetStoppedWithRecovery
htable1.put(p);
}
Thread.sleep(10000);
restartHBaseCluster(utility1, NUM_SLAVES1);
restartHBaseCluster(utility1, 1);
Admin hbaseAdmin = utility1.getAdmin();
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
Thread.sleep(10000);