Robert Bradshaw created BEAM-6404:
-------------------------------------
Summary: FnAPI translation error
Key: BEAM-6404
URL: https://issues.apache.org/jira/browse/BEAM-6404
Project: Beam
Issue Type: New Feature
Components: sdk-py-core
Reporter: Robert Bradshaw
Assignee: Robert Bradshaw
{code:java}
def run(argv=None):
parser = argparse.ArgumentParser()
_, pipeline_args = parser.parse_known_args(argv)
options = pipeline_options.PipelineOptions(pipeline_args)
numbers = [1, 2]
with beam.Pipeline(options=options) as p:
sum_1 = (p
| 'ReadNumber1' >> transforms.Create(numbers)
| 'CalculateSum1' >> beam.CombineGlobally(fn_sum))
sum_2 = (p
| 'ReadNumber2' >> transforms.Create(numbers)
| beam.ParDo(_copy_number, pvalue.AsSingleton(sum_1))
| 'CalculateSum2' >> beam.CombineGlobally(fn_sum))
_ = ((sum_1, sum_2)
| beam.Flatten()
| 'CalculateSum3' >> beam.CombineGlobally(fn_sum)
| beam.io.WriteToText('out.txt'))
run()
{code}
fails with
KeyError: u'ref_Coder_FastPrimitivesCoder_4_windowed'
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
