[FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testT…

…riggeringStopWithSavepointWithDrain
apache · Mar 15, 2024 · 5aebb04 · 5aebb04
1 parent 2b94a57
commit 5aebb04
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...ing-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java b/...ing-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java
@@ -708,7 +708,6 @@ public void acknowledgeCheckpoint(
             harness.streamTask.runMailboxLoop();
             harness.finishProcessing();
 
-            assertThat(triggerResult.isDone()).isTrue();
             assertThat(triggerResult.get()).isTrue();
             assertThat(checkpointCompleted.isDone()).isTrue();
         }