You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ha...@apache.org on 2023/08/24 13:14:30 UTC
[flink] 02/02: [FLINK-32523][test] Increase the tolerable checkpoint failure number to avoid aborting after job failing for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted(#23283)
This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a commit to branch release-1.18
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 339eb1951441f34b6c094e41d866ce5ea534d916
Author: Hangxiang Yu <ma...@gmail.com>
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(#23283)
(cherry picked from commit 5bbdc469d7f313768cb2d23e1e069fbf5b92232a)
---
.../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);