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 <se...@apache.org> Authored: Wed Mar 11 17:30:47 2015 +0100 Committer: Stephan Ewen <se...@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());
