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:
