flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [tests] Increase timeout for ProcessFailureBatchRecoveryITCase to compensate for slow Travis runs
Date Fri, 13 Mar 2015 12:03:16 GMT
Repository: flink
Updated Branches:
  refs/heads/master 378b487c4 -> 81ebe980a


[tests] Increase timeout for ProcessFailureBatchRecoveryITCase to compensate for slow Travis
runs


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

Branch: refs/heads/master
Commit: 81ebe980a9604173d25a194805d1d868687a1ba3
Parents: 378b487
Author: Stephan Ewen <sewen@apache.org>
Authored: Wed Mar 11 17:30:47 2015 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Fri Mar 13 11:17:13 2015 +0100

----------------------------------------------------------------------
 .../test/recovery/ProcessFailureBatchRecoveryITCase.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/81ebe980/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureBatchRecoveryITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureBatchRecoveryITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureBatchRecoveryITCase.java
index cceeb47..8cbd7ca 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureBatchRecoveryITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureBatchRecoveryITCase.java
@@ -162,7 +162,7 @@ public class ProcessFailureBatchRecoveryITCase {
 			env.setDegreeOfParallelism(PARALLELISM);
 			env.setNumberOfExecutionRetries(1);
 
-			final long NUM_ELEMENTS = 1000000L;
+			final long NUM_ELEMENTS = 100000L;
 			final DataSet<Long> result = env.generateSequence(1, NUM_ELEMENTS)
 
 				// make sure every mapper is involved (no one is skipped because of lazy split assignment)
@@ -190,7 +190,7 @@ public class ProcessFailureBatchRecoveryITCase {
 							}
 							else {
 								// otherwise wait so that we make slow progress
-								Thread.sleep(10);
+								Thread.sleep(100);
 							}
 						}
 						return value;
@@ -237,8 +237,8 @@ public class ProcessFailureBatchRecoveryITCase {
 			// 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 30 seconds for the program to complete
-			programTrigger.join(30000);
+			// wait for at most 2 minutes for the program to complete
+			programTrigger.join(120000);
 
 			// check that the program really finished
 			assertFalse("The program did not finish in time", programTrigger.isAlive());


Mime
View raw message