You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/15 11:49:49 UTC
[flink] 04/04: [FLINK-12111][tests] Allow multiple restarts
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 c10e18c0eb497588f0f2e27590a6f6c6a9d23563
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Fri May 10 13:50:35 2019 +0200
[FLINK-12111][tests] Allow multiple restarts
For some reason this test could fail multiple times, instead of just once.
---
.../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 473fb39..8577f9c 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
@@ -68,7 +68,7 @@ public class TaskManagerProcessFailureBatchRecoveryITCase extends AbstractTaskMa
ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("localhost", 1337, configuration);
env.setParallelism(PARALLELISM);
- env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1, 0L));
+ env.setRestartStrategy(RestartStrategies.fixedDelayRestart(2, 0L));
env.getConfig().setExecutionMode(executionMode);
env.getConfig().disableSysoutLogging();