From 5aebb04b3055fbec6a74eaf4226c4a88d3fd2d6e Mon Sep 17 00:00:00 2001 From: Jiabao Sun Date: Tue, 2 Jan 2024 14:33:17 +0800 Subject: [PATCH] [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain --- .../flink/streaming/runtime/tasks/SourceStreamTaskTest.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java index 29bcf6b599066..5e47d36040b5e 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java +++ b/flink-streaming-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(); }