[BEAM-6404] FnAPI translation error

• Type: New Feature
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: sdk-py-core
• Assignee: Unassigned
• Reporter: Robert Bradshaw
• Created: 10/Jan/19 09:58
• Updated: 13/Jan/22 21:52
• Resolved: 13/Jan/22 01:06

Description

 

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()

 
fails with 

KeyError: u'ref_Coder_FastPrimitivesCoder_4_windowed'

Issue Links

• duplicates: BEAM-5927 FnApiRunner KeyError
• links to: GitHub Pull Request #7456