(flink) branch master updated: [FLINK-39134][test] Fix UnalignedCheckpointFailureHandlingITCase

[roman]

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

roman 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 4e383d6a692 [FLINK-39134][test] Fix 
UnalignedCheckpointFailureHandlingITCase
4e383d6a692 is described below

commit 4e383d6a692e40dee1fd7b3fcb71e05eb6686e40
Author: Roman Khachatryan <khachatryan.ro...@gmail.com>
AuthorDate: Fri Feb 27 00:20:27 2026 +0100

    [FLINK-39134][test] Fix UnalignedCheckpointFailureHandlingITCase
    
    Always delay the first checkpoint (even after restart)
    to prioritize manual checkpoint so that its failure can be checked
---
 .../test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java
index b16ff4e476e..dbe19c84a7b 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java
@@ -130,6 +130,10 @@ public class UnalignedCheckpointFailureHandlingITCase {
         // use big enough interval so a manual checkpoint can be performed
         env.enableCheckpointing(100000, CheckpointingMode.EXACTLY_ONCE);
 
+        // always delay the first checkpoint (even after restart)
+        // to prioritize manual checkpoint so that its failure can be checked
+        env.getCheckpointConfig().setMinPauseBetweenCheckpoints(100000);
+
         CheckpointStorageUtils.configureCheckpointStorageWithFactory(env, 
storageFactory);
 
         env.getCheckpointConfig().enableUnalignedCheckpoints();