Repository: flink Updated Branches: refs/heads/release-1.3 a3103c2dd -> 06dfb57b8
[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/06dfb57b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06dfb57b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06dfb57b Branch: refs/heads/release-1.3 Commit: 06dfb57b86d5397b4fd9864f59998af16b8f73e7 Parents: a3103c2 Author: Till Rohrmann <trohrm...@apache.org> Authored: Tue Jun 13 10:56:25 2017 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Tue Jun 13 10:58:23 2017 +0200 ---------------------------------------------------------------------- .../runtime/executiongraph/ExecutionGraphSchedulingTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/06dfb57b/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)); } }
