diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexTest.java index 9e16f598eafb1..9c3f3509632c8 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexTest.java @@ -96,8 +96,6 @@ void testResetForNewExecutionReleasesPartitions() throws Exception { execution.markFinished(); - assertThat(releasePartitionsFuture).isNotDone(); - for (ExecutionVertex executionVertex : producerExecutionJobVertex.getTaskVertices()) { executionVertex.resetForNewExecution(); }