You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Robert Bradshaw (JIRA)" <ji...@apache.org> on 2016/07/12 21:14:20 UTC
[jira] [Closed] (BEAM-441) Python postcommit is broken
[ https://issues.apache.org/jira/browse/BEAM-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Bradshaw closed BEAM-441.
--------------------------------
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Python postcommit is broken
> ---------------------------
>
> Key: BEAM-441
> URL: https://issues.apache.org/jira/browse/BEAM-441
> Project: Beam
> Issue Type: Bug
> Components: sdk-py, testing
> Reporter: Daniel Halperin
> Assignee: Robert Bradshaw
> Fix For: 0.2.0-incubating
>
>
> Postcommit 66 and 67 failed:
> >>> JOB OUTPUT FOLLOWS
> cat job_output
> ERROR:root:Error while visiting write/WriteImpl/finalize_write
> Traceback (most recent call last):
> File "/usr/lib/python2.7/runpy.py", line 162, in _run_module_as_main
> "__main__", fname, loader, pkg_name)
> File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
> exec code in run_globals
> File "<https://builds.apache.org/job/beam_PostCommit_PythonVerify/ws/sdks/python/apache_beam/examples/wordcount.py",> line 102, in <module>
> run()
> File "<https://builds.apache.org/job/beam_PostCommit_PythonVerify/ws/sdks/python/apache_beam/examples/wordcount.py",> line 93, in run
> result = p.run()
> File "apache_beam/pipeline.py", line 161, in run
> return self.runner.run(self)
> File "apache_beam/runners/dataflow_runner.py", line 159, in run
> super(DataflowPipelineRunner, self).run(pipeline)
> File "apache_beam/runners/runner.py", line 99, in run
> pipeline.visit(RunVisitor(self))
> File "apache_beam/pipeline.py", line 184, in visit
> self._root_transform().visit(visitor, self, visited)
> File "apache_beam/pipeline.py", line 418, in visit
> part.visit(visitor, pipeline, visited)
> File "apache_beam/pipeline.py", line 418, in visit
> part.visit(visitor, pipeline, visited)
> File "apache_beam/pipeline.py", line 418, in visit
> part.visit(visitor, pipeline, visited)
> File "apache_beam/pipeline.py", line 421, in visit
> visitor.visit_transform(self)
> File "apache_beam/runners/runner.py", line 94, in visit_transform
> self.runner.run_transform(transform_node)
> File "apache_beam/runners/runner.py", line 169, in run_transform
> return m(transform_node)
> File "apache_beam/runners/dataflow_runner.py", line 367, in run_ParDo
> si_label = lookup_label(side_pval)
> File "apache_beam/runners/dataflow_runner.py", line 364, in <lambda>
> lookup_label = lambda side_pval: self._cache.get_pvalue(side_pval).step_name
> File "apache_beam/runners/runner.py", line 245, in get_pvalue
> value_with_refcount = self._cache[self.key(pvalue)]
> KeyError: '(140578717938000, None)'
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)