[
https://issues.apache.org/jira/browse/BEAM-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruoyun Huang resolved BEAM-9499.
--------------------------------
Fix Version/s: 2.21.0
Resolution: Fixed
> test_multi_triggered_gbk_side_input is failing on head
> ------------------------------------------------------
>
> Key: BEAM-9499
> URL: https://issues.apache.org/jira/browse/BEAM-9499
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow, sdk-py-core
> Reporter: Ankur Goenka
> Assignee: Ruoyun Huang
> Priority: P2
> Labels: stale-assigned
> Fix For: 2.21.0
>
> Time Spent: 1h
> Remaining Estimate: 0h
>
> test_multi_triggered_gbk_side_input is failing after it was fixed to run on
> Dataflow runner. Earlier it was always running on DirectRunner.
> Example failure:
> [https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/6004/testReport/junit/apache_beam.transforms.sideinputs_test/SideInputsTest/test_multi_triggered_gbk_side_input_7/]
> Error:
> h3. Error Message
> 'list' object has no attribute 'proto' -------------------- >> begin captured
> logging << -------------------- apache_beam.options.pipeline_options:
> WARNING: --region not set; will default to us-central1. Future releases of
> Beam will require the user to set --region explicitly, or else have a default
> set via the gcloud tool.
> {{[https://cloud.google.com/compute/docs/regions-zones]}}
> root: DEBUG: Unhandled type_constraint: Union[] root: DEBUG: Unhandled
> type_constraint: Union[] root: DEBUG: Unhandled type_constraint: Union[]
> apache_beam.runners.runner: ERROR: Error while visiting Main windowInto
> --------------------- >> end captured logging << ---------------------
> h3. Stacktrace
> File "/usr/lib/python3.6/unittest/case.py", line 59, in testPartExecutor
> yield File "/usr/lib/python3.6/unittest/case.py", line 605, in run
> testMethod() File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/transforms/sideinputs_test.py",
> line 406, in test_multi_triggered_gbk_side_input p.run() File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/testing/test_pipeline.py",
> line 112, in run False if self.not_use_test_runner_api else
> test_runner_api)) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/pipeline.py",
> line 495, in run self._options).run(False) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/pipeline.py",
> line 508, in run return self.runner.run_pipeline(self, self._options) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py",
> line 57, in run_pipeline self).run_pipeline(pipeline, options) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
> line 536, in run_pipeline self.visit_transforms(pipeline, options) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/runner.py",
> line 224, in visit_transforms pipeline.visit(RunVisitor(self)) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/pipeline.py",
> line 545, in visit self._root_transform().visit(visitor, self, visited) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/pipeline.py",
> line 1033, in visit part.visit(visitor, pipeline, visited) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/pipeline.py",
> line 1036, in visit visitor.visit_transform(self) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/runner.py",
> line 219, in visit_transform self.runner.run_transform(transform_node,
> options) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/runner.py",
> line 246, in run_transform return m(transform_node, options) File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Py_VR_Dataflow/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
> line 957, in run_ParDo PropertyNames.STEP_NAME: input_step.proto.name,
> 'list' object has no attribute 'proto' -------------------- >> begin captured
> logging << -------------------- apache_beam.options.pipeline_options:
> WARNING: --region not set; will default to us-central1. Future releases of
> Beam will require the user to set --region explicitly, or else have a default
> set via the gcloud tool.
> {{[https://cloud.google.com/compute/docs/regions-zones]}}
> root: DEBUG: Unhandled type_constraint: Union[] root: DEBUG: Unhandled
> type_constraint: Union[] root: DEBUG: Unhandled type_constraint: Union[]
> apache_beam.runners.runner: ERROR: Error while visiting Main windowInto
> --------------------- >> end captured logging << ---------------------
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
