flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/2] flink git commit: [tests] Increase timeouts for process failure tests in order to compensate for volatile CI environments (Travis)
Date Fri, 05 Jun 2015 11:47:27 GMT
Repository: flink
Updated Branches:
  refs/heads/master 0d00836ae -> 4b9e34047


[tests] Increase timeouts for process failure tests in order to compensate for volatile CI
environments (Travis)


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

Branch: refs/heads/master
Commit: 4b9e34047095da2e6a9425f67462409033a3cf14
Parents: 17cb647
Author: Stephan Ewen <sewen@apache.org>
Authored: Fri Jun 5 11:30:30 2015 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Fri Jun 5 13:46:49 2015 +0200

----------------------------------------------------------------------
 .../recovery/AbstractProcessFailureRecoveryTest.java   | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/4b9e3404/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java
b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java
index e001fc8..f40877a 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java
@@ -139,8 +139,8 @@ public abstract class AbstractProcessFailureRecoveryTest {
 			new PipeForwarder(taskManagerProcess2.getErrorStream(), processOutput2);
 
 			// we wait for the JobManager to have the two TaskManagers available
-			// wait for at most 20 seconds
-			waitUntilNumTaskManagersAreRegistered(jmActor, 2, 30000);
+			// since some of the CI environments are very hostile, we need to give this a lot of time
(2 minutes)
+			waitUntilNumTaskManagersAreRegistered(jmActor, 2, 120000);
 
 			// the program will set a marker file in each of its parallel tasks once they are ready,
so that
 			// this coordinating code is aware of this.
@@ -174,8 +174,9 @@ public abstract class AbstractProcessFailureRecoveryTest {
 			taskManagerProcess3 = new ProcessBuilder(command).start();
 			new PipeForwarder(taskManagerProcess3.getErrorStream(), processOutput3);
 
-			// we wait for the third TaskManager to register (20 seconds max)
-			waitUntilNumTaskManagersAreRegistered(jmActor, 3, 30000);
+			// we wait for the third TaskManager to register
+			// since some of the CI environments are very hostile, we need to give this a lot of time
(2 minutes)
+			waitUntilNumTaskManagersAreRegistered(jmActor, 3, 120000);
 
 			// kill one of the previous TaskManagers, triggering a failure and recovery
 			taskManagerProcess1.destroy();
@@ -184,8 +185,8 @@ public abstract class AbstractProcessFailureRecoveryTest {
 			// we create the marker file which signals the program functions tasks that they can complete
 			touchFile(new File(coordinateTempDir, PROCEED_MARKER_FILE));
 
-			// wait for at most 2 minutes for the program to complete
-			programTrigger.join(120000);
+			// wait for at most 5 minutes for the program to complete
+			programTrigger.join(300000);
 
 			// check that the program really finished
 			assertFalse("The program did not finish in time", programTrigger.isAlive());


Mime
View raw message