(flink) branch master updated: [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain

[pnowojski]

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();
         }