[
https://issues.apache.org/jira/browse/BEAM-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358781#comment-16358781
]
cclauss commented on BEAM-3670:
-------------------------------
The last message talks about **line 1453** but the text it is showing is from
the next function on **line 1456**.
[https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/core.py#L1453-L1456]
Are we sure that it is using to code that is currently on **master**?
Also Python 2.7.5 is raising a bunch of requests/urllib3 warnings that are
fixed in 2.7.9+... Current Python 2 is 2.7.14.
> 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
> Priority: Major
>
> 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)
