[jira] [Created] (BEAM-441) Python postcommit is broken

["Daniel Halperin (JIRA)" <ji...@apache.org>]

Daniel Halperin created BEAM-441:
------------------------------------

             Summary: 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


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)