[ 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)