[BEAM-79] Update to latest Gearpump API
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c2fb7c07 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c2fb7c07 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c2fb7c07 Branch: refs/heads/gearpump-runner Commit: c2fb7c077243a51d821886e56bb21ceb78c792d2 Parents: 81d94cf Author: manuzhang <owenzhang1...@gmail.com> Authored: Tue Dec 20 15:57:21 2016 +0800 Committer: manuzhang <owenzhang1...@gmail.com> Committed: Tue Dec 20 15:57:21 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c2fb7c07/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java index 8477870..4083922 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpRunner.java @@ -107,7 +107,7 @@ public class GearpumpRunner extends PipelineRunner<GearpumpPipelineResult> { TranslationContext translationContext = new TranslationContext(streamApp, options); GearpumpPipelineTranslator translator = new GearpumpPipelineTranslator(translationContext); translator.translate(pipeline); - streamApp.run(); + streamApp.submit(); return null; }