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);
 

Reply via email to