Mark Liu created BEAM-6454:
------------------------------
Summary: TypeError in DataflowRunner: object does not support
indexing
Key: BEAM-6454
URL: https://issues.apache.org/jira/browse/BEAM-6454
Project: Beam
Issue Type: Sub-task
Components: sdk-py-harness
Reporter: Mark Liu
Assignee: Mark Liu
In python 3, dict.values() returns a view, rather than a list. So need to wrap
it to a list.
Error in console output:
{code:java}
ERROR:root:Error while visiting read/Read/Impulse
Traceback (most recent call last):
File "/usr/lib/python3.5/runpy.py", line 193, in _run_module_as_main
"__main__", mod_spec)
File "/usr/lib/python3.5/runpy.py", line 85, in _run_code
exec(code, run_globals)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/examples/wordcount.py",
line 136, in <module>
run()
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/examples/wordcount.py",
line 115, in run
result = p.run()
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 405, in run
self._options).run(False)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 418, in run
return self.runner.run_pipeline(self, self._options)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
line 367, in run_pipeline
super(DataflowRunner, self).run_pipeline(pipeline, options)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/runner.py",
line 176, in run_pipeline
pipeline.visit(RunVisitor(self))
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 446, in visit
self._root_transform().visit(visitor, self, visited)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 815, in visit
part.visit(visitor, pipeline, visited)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 815, in visit
part.visit(visitor, pipeline, visited)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 815, in visit
part.visit(visitor, pipeline, visited)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/pipeline.py",
line 818, in visit
visitor.visit_transform(self)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/runner.py",
line 171, in visit_transform
self.runner.run_transform(transform_node, options)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/runner.py",
line 214, in run_transform
return m(transform_node, options)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
line 532, in run_Impulse
step.encoding = self._get_encoded_output_coder(transform_node)
File
"/usr/local/google/home/markliu/tmp/beam4/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
line 461, in _get_encoded_output_coder
transform_node.outputs.values()[0].pipeline._options)
TypeError: 'dict_values' object does not support indexing
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
