(flink) branch master updated: [FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot.

[junrui]

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

junrui 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 78e0d01f0c6 [FLINK-37761][runtime] Fix unstable test 
testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot.
78e0d01f0c6 is described below

commit 78e0d01f0c6d55d3d2f986e5c142079fef7a88f1
Author: JunRuiLee <jrlee....@gmail.com>
AuthorDate: Thu May 22 11:00:07 2025 +0800

    [FLINK-37761][runtime] Fix unstable test 
testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot.
---
 .../runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java    | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java
index 57a235765f7..2146e78954a 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java
@@ -413,9 +413,12 @@ public class BatchJobRecoveryTest {
 
             // check middle task0 is CREATED because it's waiting source task0 
finished.
             if (vertex.getParallelSubtaskIndex() == subtaskIndex) {
-                ExecutionState expectedState =
-                        isBlockingShuffle ? ExecutionState.CREATED : 
ExecutionState.DEPLOYING;
-                
assertThat(vertex.getExecutionState()).isEqualTo(expectedState);
+                if (isBlockingShuffle) {
+                    
assertThat(vertex.getExecutionState()).isEqualTo(ExecutionState.CREATED);
+                } else {
+                    assertThat(vertex.getExecutionState().ordinal())
+                            
.isLessThanOrEqualTo(ExecutionState.DEPLOYING.ordinal());
+                }
                 continue;
             }