Skip to content

Commit

Permalink
Fix tests to clean up after themselves.
Browse files Browse the repository at this point in the history
  • Loading branch information
zpinto committed Oct 26, 2023
1 parent c42078f commit 6d0a3f7
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -405,6 +405,8 @@ public void testMarkEvacuationAfterEMM() throws Exception {
Assert.assertTrue(newPAssignedParticipants.containsAll(currentActiveInstances));
}
Assert.assertTrue(_admin.isReadyForPreparingJoiningCluster(CLUSTER_NAME, instanceToEvacuate));

_stateModelDelay = 3L;
}

@Test(dependsOnMethods = "testMarkEvacuationAfterEMM")
Expand Down Expand Up @@ -441,6 +443,9 @@ public void testEvacuationWithOfflineInstancesInCluster() throws Exception {
return true;
}, 30000);
}

resetInstances();
dropTestDBs(ImmutableSet.of("TEST_DB3_DELAYED_CRUSHED", "TEST_DB4_DELAYED_WAGED"));
}

@Test(expectedExceptions = HelixException.class, dependsOnMethods = "testEvacuationWithOfflineInstancesInCluster")
Expand All @@ -450,7 +455,6 @@ public void testAddingNodeWithSwapOutInstanceOperation() throws Exception {
System.currentTimeMillis()));

resetInstances();
dropTestDBs(ImmutableSet.of("TEST_DB3_DELAYED_CRUSHED", "TEST_DB4_DELAYED_WAGED"));

// Set instance's InstanceOperation to SWAP_OUT
String instanceToSwapOutName = _participants.get(0).getInstanceName();
Expand Down

0 comments on commit 6d0a3f7

Please sign in to comment.