(flink) branch master updated: [FLINK-39117][tests] Fix flaky ChainUnionTest by tolerating CHECKPOINT_COORDINATOR_SUSPEND exception (#27664)

[panyuepeng]

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

panyuepeng 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 f302c4729e9 [FLINK-39117][tests] Fix flaky ChainUnionTest by 
tolerating CHECKPOINT_COORDINATOR_SUSPEND exception (#27664)
f302c4729e9 is described below

commit f302c4729e9f8b269d27757880f3ce7d5012840c
Author: Shekhar Prasad Rajak <5774448+shekharra...@users.noreply.github.com>
AuthorDate: Wed Apr 1 07:21:58 2026 +0530

    [FLINK-39117][tests] Fix flaky ChainUnionTest by tolerating 
CHECKPOINT_COORDINATOR_SUSPEND exception (#27664)
    
    Co-authored-by: Shekhar Rajak <sra...@atlassian.com>
---
 .../test/state/operator/restore/AbstractOperatorRestoreTestBase.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
index 612953f4379..43a0f861e37 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
@@ -113,6 +113,8 @@ public abstract class AbstractOperatorRestoreTestBase 
implements MigrationTest {
                                             .message(),
                                     CheckpointFailureReason
                                             
.CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER
+                                            .message(),
+                                    
CheckpointFailureReason.CHECKPOINT_COORDINATOR_SUSPEND
                                             .message())
                             
.map(AbstractOperatorRestoreTestBase::escapeRegexCharacters)
                             .collect(Collectors.joining(")|(", "(", ")")));