|
@@ -333,6 +333,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
|
|
|
private void testExpectedReplication(int replicationFactor,
|
|
|
int expectedReplicasInRead) throws IOException {
|
|
|
+ setup();
|
|
|
startCluster(1, 5);
|
|
|
|
|
|
final Path file = new Path("/testExpectedReplication.dat");
|
|
@@ -352,6 +353,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
nodeOutofService));
|
|
|
|
|
|
cleanupFile(fileSys, file);
|
|
|
+ teardown();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -492,6 +494,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
|
|
|
private void testDecommissionDifferentNodeAfterMaintenance(int repl)
|
|
|
throws Exception {
|
|
|
+ setup();
|
|
|
startCluster(1, 5);
|
|
|
|
|
|
final Path file =
|
|
@@ -519,6 +522,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
assertNull(checkWithRetry(ns, fileSys, file, repl + 1, null));
|
|
|
|
|
|
cleanupFile(fileSys, file);
|
|
|
+ teardown();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -583,6 +587,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
*/
|
|
|
private void testChangeReplicationFactor(int oldFactor, int newFactor,
|
|
|
int expectedLiveReplicas) throws IOException {
|
|
|
+ setup();
|
|
|
LOG.info("Starting testChangeReplicationFactor {} {} {}",
|
|
|
oldFactor, newFactor, expectedLiveReplicas);
|
|
|
startCluster(1, 5);
|
|
@@ -615,6 +620,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest {
|
|
|
assertNull(checkWithRetry(ns, fileSys, file, newFactor, null));
|
|
|
|
|
|
cleanupFile(fileSys, file);
|
|
|
+ teardown();
|
|
|
}
|
|
|
|
|
|
|