[flink] 01/02: [FLINK-21596] Increase time out for the CheckpointFailureManagerITCase

[dw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 7adeacd3e3f61d5bbfc3e10551a5cb126bad19de
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Mon Mar 15 15:57:29 2021 +0100

    [FLINK-21596] Increase time out for the CheckpointFailureManagerITCase
---
 .../flink/test/checkpointing/CheckpointFailureManagerITCase.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointFailureManagerITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointFailureManagerITCase.java
index 4042748..fa70dab 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointFailureManagerITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointFailureManagerITCase.java
@@ -90,10 +90,10 @@ public class CheckpointFailureManagerITCase extends TestLogger {
         }
     }
 
-    @Test(timeout = 10000)
+    @Test(timeout = 20_000)
     public void testAsyncCheckpointFailureTriggerJobFailed() throws Exception {
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
-        env.enableCheckpointing(100);
+        env.enableCheckpointing(500);
         env.setRestartStrategy(RestartStrategies.noRestart());
         env.setStateBackend(new AsyncFailureStateBackend());
         env.addSource(new StringGeneratingSourceFunction()).addSink(new DiscardingSink<>());