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/12/21 20:23:56 UTC

[48/50] incubator-beam git commit: [BEAM-79] Update to latest Gearpump API

[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 <ow...@gmail.com>
Authored: Tue Dec 20 15:57:21 2016 +0800
Committer: manuzhang <ow...@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;
   }