[beam] branch master updated: [BEAM-10322] allow only single assignment to producing stages by pcollection map

[pabloem]

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

pabloem 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 592ab72  [BEAM-10322] allow only single assignment to producing stages 
by pcollection map
     new 709c2c5  Merge pull request #12086 from [BEAM-10322] allow only single 
assignment to producing stages by pcol…
592ab72 is described below

commit 592ab72d4c98f54eac52e0e37834177af31b5298
Author: Heejong Lee <heej...@gmail.com>
AuthorDate: Wed Jun 24 18:28:24 2020 -0700

    [BEAM-10322] allow only single assignment to producing stages by 
pcollection map
---
 sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py 
b/sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py
index acf04b7..251a696 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py
@@ -375,6 +375,8 @@ class FnApiRunnerExecutionContext(object):
         for o in transform.outputs.values():
           if o in s.side_inputs():
             continue
+          if o in producing_stages_by_pcoll:
+            continue
           producing_stages_by_pcoll[o] = s
 
     for side_pc in all_side_inputs: