You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/06/15 08:11:38 UTC
[2/2] 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/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 <tg...@google.com>
Authored: Tue Jun 14 15:49:34 2016 -0700
Committer: Dan Halperin <dh...@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);
}