Skip to content
Permalink
Browse files
[FLINK-27533][coordination][tests] Remove retry attempt limit
The test could fail if the polling loop ran too quickly or if the timing was just right that it always missed the restarting state.
Remove the limit and just wait for as long as needed.
  • Loading branch information
zentol committed May 6, 2022
1 parent 9d174b3 commit 88a180392b1b67a279b59a6bb71e615907119a0f
Showing 1 changed file with 1 addition and 2 deletions.
@@ -126,8 +126,7 @@ public void testJobCancellationWhileRestartingSucceeds() throws Exception {

// wait until we are in RESTARTING state
CommonTestUtils.waitUntilCondition(
() -> miniCluster.getJobStatus(jobGraph.getJobID()).get() == JobStatus.RESTARTING,
5);
() -> miniCluster.getJobStatus(jobGraph.getJobID()).get() == JobStatus.RESTARTING);

// now cancel while in RESTARTING state
miniCluster.cancelJob(jobGraph.getJobID()).get();

0 comments on commit 88a1803

Please sign in to comment.