Details
-
New Feature
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
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'
Attachments
Issue Links
- duplicates
-
BEAM-5927 FnApiRunner KeyError
- Resolved
- links to