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 <[email protected]> Authored: Tue Jun 14 15:49:34 2016 -0700 Committer: Davor Bonaci <[email protected]> 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); }
