This is an automated email from the ASF dual-hosted git repository. hangxiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5bbdc469d7f313768cb2d23e1e069fbf5b92232a Author: Hangxiang Yu <[email protected]> AuthorDate: Wed Aug 2 22:25:14 2023 +0800 [FLINK-32523][test] Increase the tolerable checkpoint failure number to avoid aborting after job failing for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted --- .../apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java index a3994883dcd..ac0c997ab53 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java @@ -156,7 +156,7 @@ public class NotifyCheckpointAbortedITCase extends TestLogger { final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.enableCheckpointing(200, CheckpointingMode.EXACTLY_ONCE); env.getCheckpointConfig().enableUnalignedCheckpoints(unalignedCheckpointEnabled); - env.getCheckpointConfig().setTolerableCheckpointFailureNumber(1); + env.getCheckpointConfig().setTolerableCheckpointFailureNumber(2); env.disableOperatorChaining(); env.setParallelism(1);
