Robert Bradshaw created BEAM-3393:
-------------------------------------
Summary: Empty flattens cannot be used as side inputs.
Key: BEAM-3393
URL: https://issues.apache.org/jira/browse/BEAM-3393
Project: Beam
Issue Type: Bug
Components: sdk-py-core
Reporter: Robert Bradshaw
Assignee: Ahmet Altay
{{with beam.Pipeline() as p:
main = p | "CM" >> beam.Create([])
side1 = p | "C1" >> beam.Create([])
side2 = p | "C2" >> beam.Create([])
side = (side1, side2) | beam.Flatten()
res = main | beam.Map(lambda x, side: x, beam.pvalue.AsList(side))
}}
results in
{{
File
"/Users/robertwb/Work/beam/incubator-beam/sdks/python/apache_beam/runners/direct/evaluation_context.py",
line 84, in add_values
assert not view.has_result
}}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
