This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c0b9089f1172815b9c711f04a28ca4657acd0357 Author: Piotr Nowojski <[email protected]> AuthorDate: Thu Oct 29 17:51:49 2020 +0100 [FLINK-19681][tests] Adjust alignmentTimeout in unaligned checkpoint ITCases --- .../flink/test/checkpointing/UnalignedCheckpointCompatibilityITCase.java | 1 + .../org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java | 1 + 2 files changed, 2 insertions(+) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCompatibilityITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCompatibilityITCase.java index 6d69576..2e054a8 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCompatibilityITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCompatibilityITCase.java @@ -186,6 +186,7 @@ public class UnalignedCheckpointCompatibilityITCase extends TestLogger { env.setParallelism(PARALLELISM); env.setRestartStrategy(new RestartStrategies.NoRestartStrategyConfiguration()); env.getCheckpointConfig().enableUnalignedCheckpoints(!isAligned); + env.getCheckpointConfig().setAlignmentTimeout(0); env.getCheckpointConfig().enableExternalizedCheckpoints(RETAIN_ON_CANCELLATION); if (checkpointingInterval > 0) { env.enableCheckpointing(checkpointingInterval); diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java index 2acf7b6..2904de7 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java @@ -538,6 +538,7 @@ public abstract class UnalignedCheckpointTestBase extends TestLogger { final LocalStreamEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(parallelism, conf); env.enableCheckpointing(100); + env.getCheckpointConfig().setAlignmentTimeout(1); env.setParallelism(parallelism); env.setRestartStrategy(RestartStrategies.fixedDelayRestart(generateCheckpoint ? expectedFailures / 2 : expectedFailures, Time.milliseconds(100))); env.getCheckpointConfig().enableUnalignedCheckpoints(true);
