diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusAfterLagging.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusAfterLagging.java index 1993d349d24..0ec98e92aaa 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusAfterLagging.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusAfterLagging.java @@ -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)); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusBothNormalAndRecoveryLagging.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusBothNormalAndRecoveryLagging.java index 4bb41f8265c..75255bbe922 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusBothNormalAndRecoveryLagging.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusBothNormalAndRecoveryLagging.java @@ -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); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNewOp.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNewOp.java index fb3f16bb6b7..a8f266ad24b 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNewOp.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNewOp.java @@ -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++) { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNoOps.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNoOps.java index 76d12b29b59..6625eb5278d 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNoOps.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedNoOps.java @@ -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); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedWithRecovery.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedWithRecovery.java index 800fa822d96..0b5f6e83838 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedWithRecovery.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStatusSourceStartedTargetStoppedWithRecovery.java @@ -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);