This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 5aebb04b305 [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain 5aebb04b305 is described below commit 5aebb04b3055fbec6a74eaf4226c4a88d3fd2d6e Author: Jiabao Sun <jiabao....@xtransfer.cn> AuthorDate: Tue Jan 2 14:33:17 2024 +0800 [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain --- .../org/apache/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 29bcf6b5990..5e47d36040b 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 @@ class SourceStreamTaskTest extends SourceStreamTaskTestBase { harness.streamTask.runMailboxLoop(); harness.finishProcessing(); - assertThat(triggerResult.isDone()).isTrue(); assertThat(triggerResult.get()).isTrue(); assertThat(checkpointCompleted.isDone()).isTrue(); }