[beam] branch master updated: [BEAM-8037] add beam_fn_api experiment when using FlinkRunner

[ibzib]

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

ibzib 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 5ec2b3f  [BEAM-8037] add beam_fn_api experiment when using FlinkRunner
     new 59a60b8  Merge pull request #9402 from ibzib/flink-override
5ec2b3f is described below

commit 5ec2b3fa9c5a8b9ba655642d61a92807a5c3e2f3
Author: Kyle Weaver <kcwea...@google.com>
AuthorDate: Thu Aug 22 10:43:30 2019 -0700

    [BEAM-8037] add beam_fn_api experiment when using FlinkRunner
---
 sdks/python/apache_beam/pipeline.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/pipeline.py 
b/sdks/python/apache_beam/pipeline.py
index 25f9a1f..2c0d7b2 100644
--- a/sdks/python/apache_beam/pipeline.py
+++ b/sdks/python/apache_beam/pipeline.py
@@ -156,7 +156,8 @@ class Pipeline(object):
 
     # set default experiments for portable runner
     # (needs to occur prior to pipeline construction)
-    if self._options.view_as(StandardOptions).runner == 'PortableRunner':
+    portable_runners = ['PortableRunner', 'FlinkRunner']
+    if self._options.view_as(StandardOptions).runner in portable_runners:
       experiments = (self._options.view_as(DebugOptions).experiments or [])
       if not 'beam_fn_api' in experiments:
         experiments.append('beam_fn_api')