beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ahmet Altay (JIRA)" <j...@apache.org>
Subject [jira] [Created] (BEAM-2107) PBegin | Write produces obscure error
Date Thu, 27 Apr 2017 23:29:04 GMT
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)

Mime
View raw message