You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/06/20 22:16:01 UTC
[08/50] [abbrv] incubator-beam git commit: Explicitly set the Runner
in TestFlinkPipelineRunner
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/90bb20ee
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/90bb20ee
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/90bb20ee
Branch: refs/heads/python-sdk
Commit: 90bb20ee6738c57bc25f47e2d80690fb721b562e
Parents: 0065851
Author: Thomas Groh <tg...@google.com>
Authored: Tue Jun 14 15:49:34 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Mon Jun 20 15:14:28 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/90bb20ee/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);
}