[beam] branch master updated: [BEAM-6543] Pass on PipelineOptions from TestFlinkRunner to FlinkRunner

[mx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 400fe8a  [BEAM-6543] Pass on PipelineOptions from TestFlinkRunner to FlinkRunner
     new 7c53c3e  Merge pull request #7671: [BEAM-6543] Pass on PipelineOptions from TestFlinkRunner to FlinkRunner
400fe8a is described below

commit 400fe8aa53e97ff3cd0fe005d993a1c119cc6318
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Wed Jan 30 11:40:21 2019 +0100

    [BEAM-6543] Pass on PipelineOptions from TestFlinkRunner to FlinkRunner
---
 .../src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java
index 0c45a07..4d7c3c0 100644
--- a/runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java
+++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java
@@ -41,7 +41,7 @@ public class TestFlinkRunner extends PipelineRunner<PipelineResult> {
   }
 
   public static TestFlinkRunner fromOptions(PipelineOptions options) {
-    FlinkPipelineOptions flinkOptions = PipelineOptionsFactory.as(FlinkPipelineOptions.class);
+    FlinkPipelineOptions flinkOptions = options.as(FlinkPipelineOptions.class);
     return new TestFlinkRunner(flinkOptions);
   }