reduce timeout to wait for result
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7613ec44 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7613ec44 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7613ec44 Branch: refs/heads/gearpump-runner Commit: 7613ec44cedf12d1e7bf80e8bb6a505f09653c4f Parents: b2d326f Author: manuzhang <owenzhang1...@gmail.com> Authored: Mon Jan 16 13:25:12 2017 +0800 Committer: manuzhang <owenzhang1...@gmail.com> Committed: Mon Jan 16 13:25:12 2017 +0800 ---------------------------------------------------------------------- .../org/apache/beam/runners/gearpump/GearpumpPipelineResult.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/7613ec44/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java index 9c8f7b3..3dd78de 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java @@ -42,8 +42,8 @@ public class GearpumpPipelineResult implements PipelineResult { private final ClientContext client; private final int appId; - private final Duration defaultWaitDuration = Duration.standardSeconds(60); - private final Duration defaultWaitInterval = Duration.standardSeconds(10); + private final Duration defaultWaitDuration = Duration.standardSeconds(30); + private final Duration defaultWaitInterval = Duration.standardSeconds(5); public GearpumpPipelineResult(ClientContext client, int appId) { this.client = client;
