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 2016/11/08 03:41:48 UTC
[49/50] incubator-beam git commit: [BEAM-79] update
GearpumpPipelineResult
[BEAM-79] update GearpumpPipelineResult
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2a96a17f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2a96a17f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2a96a17f
Branch: refs/heads/gearpump-runner
Commit: 2a96a17f2fe9a391ec5b2f0b4bea223530c1ba34
Parents: 0c36228
Author: manuzhang <ow...@gmail.com>
Authored: Tue Nov 8 11:25:27 2016 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Tue Nov 8 11:30:26 2016 +0800
----------------------------------------------------------------------
.../org/apache/beam/runners/gearpump/GearpumpPipelineResult.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2a96a17f/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 e7c621e..ed1201d 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
@@ -44,12 +44,12 @@ public class GearpumpPipelineResult implements PipelineResult {
}
@Override
- public State waitUntilFinish(Duration duration) throws IOException, InterruptedException {
+ public State waitUntilFinish(Duration duration) {
return null;
}
@Override
- public State waitUntilFinish() throws IOException, InterruptedException {
+ public State waitUntilFinish() {
return null;
}