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
commit c06640f9331683fee110a5d6836140164e0b1fc2 Author: Roman <[email protected]> AuthorDate: Mon Jan 26 10:12:32 2026 +0000 [hotfix][tests] Increase min pause between checkpoints in migration tests --- .../test/state/operator/restore/AbstractOperatorRestoreTestBase.java | 3 +++ 1 file changed, 3 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 3ba517b8dd1..99403d6bb08 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 @@ -258,6 +258,9 @@ public abstract class AbstractOperatorRestoreTestBase extends TestLogger impleme private JobGraph createJobGraph(ExecutionMode mode) { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.enableCheckpointing(500, CheckpointingMode.EXACTLY_ONCE); + // set high min pause between checkpoints to delay the 1st checkpoint + // because the test assumes that manual checkpoint will be triggered first + env.getCheckpointConfig().setMinPauseBetweenCheckpoints(600_000); RestartStrategyUtils.configureNoRestartStrategy(env); StateBackendUtils.configureHashMapStateBackend(env); CheckpointStorageUtils.configureJobManagerCheckpointStorage(env);
