This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 44e289100f2294c3e5deeccd4e84b9df4a6656de Author: Chesnay Schepler <[email protected]> AuthorDate: Tue Nov 2 15:19:47 2021 +0100 [FLINK-24706][tests] Increase restart delay to 5 seconds --- .../test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java index 5bbd3fb..aca91ea 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java @@ -67,7 +67,7 @@ public class TaskManagerProcessFailureBatchRecoveryITCase ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("localhost", 1337, configuration); env.setParallelism(PARALLELISM); - env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1, 1500L)); + env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1, 5000L)); env.getConfig().setExecutionMode(executionMode); final long numElements = 100000L;
