You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Robert Bradshaw (JIRA)" <ji...@apache.org> on 2017/12/23 00:57:00 UTC

[jira] [Created] (BEAM-3393) Empty flattens cannot be used as side inputs.

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)