You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/06/13 08:58:03 UTC
flink git commit: [FLINK-6744] [tests] Harden
ExecutionGraphSchedulingTest.testDeployPipelinedConnectedComponentsTogether
Repository: flink
Updated Branches:
refs/heads/master ab2fc0230 -> 1a658775c
[FLINK-6744] [tests] Harden ExecutionGraphSchedulingTest.testDeployPipelinedConnectedComponentsTogether
Increase the timeout for the verification check that the TaskManagerGateway#submitTask
method has been called.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a658775
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1a658775
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1a658775
Branch: refs/heads/master
Commit: 1a658775c28f622e127ea256036d8604248e7500
Parents: ab2fc02
Author: Till Rohrmann <tr...@apache.org>
Authored: Tue Jun 13 10:56:25 2017 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Jun 13 10:56:25 2017 +0200
----------------------------------------------------------------------
.../runtime/executiongraph/ExecutionGraphSchedulingTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1a658775/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
index 1eecd4a..c2eea5c 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
@@ -243,10 +243,10 @@ public class ExecutionGraphSchedulingTest extends TestLogger {
// verify that all deployments have happened
for (TaskManagerGateway gateway : sourceTaskManagers) {
- verify(gateway, timeout(50)).submitTask(any(TaskDeploymentDescriptor.class), any(Time.class));
+ verify(gateway, timeout(500L)).submitTask(any(TaskDeploymentDescriptor.class), any(Time.class));
}
for (TaskManagerGateway gateway : targetTaskManagers) {
- verify(gateway, timeout(50)).submitTask(any(TaskDeploymentDescriptor.class), any(Time.class));
+ verify(gateway, timeout(500L)).submitTask(any(TaskDeploymentDescriptor.class), any(Time.class));
}
}