[
https://issues.apache.org/jira/browse/BEAM-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17546356#comment-17546356
]
Kenneth Knowles commented on BEAM-2107:
---------------------------------------
This issue has been migrated to https://github.com/apache/beam/issues/18237
> PBegin | Write produces obscure error
> -------------------------------------
>
> Key: BEAM-2107
> URL: https://issues.apache.org/jira/browse/BEAM-2107
> Project: Beam
> Issue Type: Improvement
> Components: sdk-py-core
> Reporter: Ahmet Altay
> Priority: P3
>
> Repro: {{p| beam.io.WriteToText(output_file))||
> produces:
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 157, in run
> self.to_runner_api(), self.runner, self.options).run(False)
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 334, in to_runner_api
> root_transform_id = context.transforms.get_id(self._root_transform())
> File
> "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/runners/pipeline_context.py",
> line 52, in get_id
> self._id_to_proto[id] = obj.to_runner_api(self._pipeline_context)
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 523, in to_runner_api
> subtransforms=[context.transforms.get_id(part) for part in self.parts],
> File
> "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/runners/pipeline_context.py",
> line 52, in get_id
> self._id_to_proto[id] = obj.to_runner_api(self._pipeline_context)
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 523, in to_runner_api
> subtransforms=[context.transforms.get_id(part) for part in self.parts],
> File
> "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/runners/pipeline_context.py",
> line 52, in get_id
> self._id_to_proto[id] = obj.to_runner_api(self._pipeline_context)
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 528, in to_runner_api
> for tag, out in self.named_outputs().items()},
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pipeline.py",
> line 528, in <dictcomp>
> for tag, out in self.named_outputs().items()},
> File
> "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/runners/pipeline_context.py",
> line 52, in get_id
> self._id_to_proto[id] = obj.to_runner_api(self._pipeline_context)
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pvalue.py",
> line 128, in to_runner_api
> self.windowing))
> File "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/pvalue.py",
> line 110, in windowing
> self.producer.inputs)
> File
> "/Users/tiborkiss/workspace/beam/sdks/python/apache_beam/transforms/ptransform.py",
> line 336, in get_windowing
> return inputs[0].windowing
> AttributeError: 'PBegin' object has no attribute 'windowing'
> cc: [[email protected]]
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
