Ahmet Altay created BEAM-3670:
---------------------------------
Summary: DirectRunner: TypeError: 'KeyedWorkItem' object is not
iterable
Key: BEAM-3670
URL: https://issues.apache.org/jira/browse/BEAM-3670
Project: Beam
Issue Type: Bug
Components: sdk-py-core
Reporter: Ahmet Altay
Assignee: Charles Chen
I see the following error in a pre-commit test with no code changes:
[https://builds.apache.org/job/beam_PreCommit_Python_MavenInstall/2661/org.apache.beam$beam-sdks-python/console]
root: ERROR: Exception at bundle
<apache_beam.runners.direct.bundle_factory._Bundle object at 0x7fa5f5cdafc8>,
due to an exception.
Traceback (most recent call last):
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/executor.py",
line 305, in call
side_input_values)
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/executor.py",
line 338, in attempt_call
evaluator.process_element(value)
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/transform_evaluator.py",
line 560, in process_element
self.runner.process(element)
File "apache_beam/runners/common.py", line 468, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:13915)
def process(self, windowed_value):
File "apache_beam/runners/common.py", line 474, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:13719)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 515, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:14934)
raise new_exn, None, original_traceback
File "apache_beam/runners/common.py", line 472, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:13632)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 270, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:9084)
windowed_value, self.process_method(windowed_value.value))
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/transforms/core.py",
line 1453, in process
k, vs = element
TypeError: 'KeyedWorkItem' object is not iterable [while running
'assert_that/Group/GroupByKey/GroupByWindow']
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
