[
https://issues.apache.org/jira/browse/BEAM-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Liu resolved BEAM-6454.
----------------------------
Resolution: Fixed
Fix Version/s: 2.11.0
> TypeError in DataflowRunner: dict_values 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
> Priority: Major
> Fix For: 2.11.0
>
> Time Spent: 40m
> Remaining Estimate: 0h
>
> 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)
