Skip to content

Commit 78e4aea

Browse files
committed
HBASE-22472 The newly split TestReplicationStatus* tests are flaky
1 parent 2823090 commit 78e4aea

5 files changed

+6
-6
lines changed

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusAfterLagging.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public class TestReplicationStatusAfterLagging extends TestReplicationBase {
4545
@Test
4646
public void testReplicationStatusAfterLagging() throws Exception {
4747
utility2.shutdownMiniHBaseCluster();
48-
restartHBaseCluster(utility1, NUM_SLAVES1);
48+
restartHBaseCluster(utility1, 1);
4949
// add some values to cluster 1
5050
for (int i = 0; i < NB_ROWS_IN_BATCH; i++) {
5151
Put p = new Put(Bytes.toBytes("row" + i));

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusBothNormalAndRecoveryLagging.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public void testReplicationStatusBothNormalAndRecoveryLagging() throws Exception
5252
htable1.put(p);
5353
}
5454
Thread.sleep(10000);
55-
restartHBaseCluster(utility1, NUM_SLAVES1);
55+
restartHBaseCluster(utility1, 1);
5656
Admin hbaseAdmin = utility1.getAdmin();
5757
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
5858
Thread.sleep(10000);

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNewOp.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public class TestReplicationStatusSourceStartedTargetStoppedNewOp extends TestRe
4646
@Test
4747
public void testReplicationStatusSourceStartedTargetStoppedNewOp() throws Exception {
4848
utility2.shutdownMiniHBaseCluster();
49-
restartHBaseCluster(utility1, NUM_SLAVES1);
49+
restartHBaseCluster(utility1, 1);
5050
Admin hbaseAdmin = utility1.getAdmin();
5151
// add some values to source cluster
5252
for (int i = 0; i < NB_ROWS_IN_BATCH; i++) {

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNoOps.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,9 @@ public class TestReplicationStatusSourceStartedTargetStoppedNoOps extends TestRe
4141
HBaseClassTestRule.forClass(TestReplicationStatusSourceStartedTargetStoppedNoOps.class);
4242

4343
@Test
44-
public void c() throws Exception {
44+
public void testReplicationStatusSourceStartedTargetStoppedNoOps() throws Exception {
4545
utility2.shutdownMiniHBaseCluster();
46-
restartHBaseCluster(utility1, NUM_SLAVES1);
46+
restartHBaseCluster(utility1, 1);
4747
Admin hbaseAdmin = utility1.getAdmin();
4848
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
4949
Thread.sleep(10000);

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedWithRecovery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public void testReplicationStatusSourceStartedTargetStoppedWithRecovery() throws
5454
htable1.put(p);
5555
}
5656
Thread.sleep(10000);
57-
restartHBaseCluster(utility1, NUM_SLAVES1);
57+
restartHBaseCluster(utility1, 1);
5858
Admin hbaseAdmin = utility1.getAdmin();
5959
ServerName serverName = utility1.getHBaseCluster().getRegionServer(0).getServerName();
6060
Thread.sleep(10000);

0 commit comments

Comments
 (0)