You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ju...@apache.org on 2025/05/22 11:08:09 UTC
(flink) branch master updated: [FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot.
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 <jr...@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;
}