You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Ahmet Altay (JIRA)" <ji...@apache.org> on 2017/04/27 23:29:04 UTC
[jira] [Created] (BEAM-2107) PBegin | Write produces obscure error
Ahmet Altay created BEAM-2107:
---------------------------------
Summary: 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
Reporter: Ahmet Altay
Priority: Minor
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: [~tibor.kiss@gmail.com]
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)