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:37 UTC
[1/2] incubator-beam git commit: Closes #463
Repository: incubator-beam
Updated Branches:
refs/heads/master 315b3c8e3 -> 63e7b1dce
Closes #463
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63e7b1dc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/63e7b1dc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/63e7b1dc
Branch: refs/heads/master
Commit: 63e7b1dce5d7bbea30c4cb4f3208cfd3e47627d6
Parents: 315b3c8 fbdfba4
Author: Dan Halperin <dh...@google.com>
Authored: Wed Jun 15 01:11:26 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(+)
----------------------------------------------------------------------
[2/2] incubator-beam git commit: Explicitly set the Runner in
TestFlinkPipelineRunner
Posted by dh...@apache.org.
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);
}