You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/01/24 03:23:21 UTC
[09/12] beam git commit: reduce timeout to wait for result
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 <ow...@gmail.com>
Authored: Mon Jan 16 13:25:12 2017 +0800
Committer: manuzhang <ow...@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;