beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] incubator-beam git commit: Explicitly set the Runner in TestFlinkPipelineRunner
Date Wed, 15 Jun 2016 08:11:38 GMT
Explicitly set the Runner in TestFlinkPipelineRunner

This ensures that the created PipelineOptions are valid if the
DirectRunner is not on the classpath.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fbdfba40
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fbdfba40
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fbdfba40

Branch: refs/heads/master
Commit: fbdfba404c7ac92e5b379a1d85c8d62a91d6fdce
Parents: 315b3c8
Author: Thomas Groh <tgroh@google.com>
Authored: Tue Jun 14 15:49:34 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed Jun 15 01:11:26 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fbdfba40/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java
b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java
index 139aebf..a55acb7 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkPipelineRunner.java
@@ -45,6 +45,7 @@ public class TestFlinkPipelineRunner extends PipelineRunner<FlinkRunnerResult>
{
 
   public static TestFlinkPipelineRunner create(boolean streaming) {
     FlinkPipelineOptions flinkOptions = PipelineOptionsFactory.as(FlinkPipelineOptions.class);
+    flinkOptions.setRunner(TestFlinkPipelineRunner.class);
     flinkOptions.setStreaming(streaming);
     return TestFlinkPipelineRunner.fromOptions(flinkOptions);
   }


Mime
View raw message