flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase
Date Thu, 16 Feb 2017 09:53:16 GMT
Repository: flink
Updated Branches:
  refs/heads/master 67e3d9d44 -> f250d95b7


[hotfix] [tests] Stabilize FastFailuresITCase

The test triggers 200 immediate failures and recoveries. The restart strategy allowed 200
restarts.

It may happen that another failure occurs as during the execution, in which case the restart
attempts are not
sufficient.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f250d95b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f250d95b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f250d95b

Branch: refs/heads/master
Commit: f250d95b74fa5713f35a61dd5537aa419d1f12c6
Parents: 67e3d9d
Author: Stephan Ewen <sewen@apache.org>
Authored: Wed Feb 15 18:49:29 2017 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Thu Feb 16 10:51:30 2017 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/test/recovery/FastFailuresITCase.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f250d95b/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
index 8a43ee4..d80c826 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
@@ -58,7 +58,7 @@ public class FastFailuresITCase extends TestLogger {
 		env.getConfig().disableSysoutLogging();
 		env.setParallelism(4);
 		env.enableCheckpointing(1000);
-		env.getConfig().setRestartStrategy(RestartStrategies.fixedDelayRestart(200, 0));
+		env.getConfig().setRestartStrategy(RestartStrategies.fixedDelayRestart(210, 0));
 		
 		DataStream<Tuple2<Integer, Integer>> input = env.addSource(new RichSourceFunction<Tuple2<Integer,
Integer>>() {
 


Mime
View raw message