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

[mapohl]

This is an automated email from the ASF dual-hosted git repository.

mapohl pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.19 by this push:
     new ece4faee055 [FLINK-33816][streaming] Fix unstable test 
SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain
ece4faee055 is described below

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