[
https://issues.apache.org/jira/browse/BEAM-9983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pablo Estrada resolved BEAM-9983.
---------------------------------
Fix Version/s: Not applicable
Resolution: Fixed
this pr was reverted and rolled-forward later on with fixes.
> bigquery_read_it_test.ReadNewTypesTests.test_iobase_source failing
> ------------------------------------------------------------------
>
> Key: BEAM-9983
> URL: https://issues.apache.org/jira/browse/BEAM-9983
> Project: Beam
> Issue Type: Bug
> Components: io-py-gcp, test-failures
> Reporter: Kyle Weaver
> Assignee: Pablo Estrada
> Priority: Major
> Fix For: Not applicable
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> This failure seems to afflict all Python postcommits.
> apache_beam.io.gcp.bigquery_read_it_test.ReadNewTypesTests.test_iobase_source
> (from nosetests)
> Failing for the past 1 build (Since Failed#2429 )
> Took 9 min 57 sec.
> Error Message
> Dataflow pipeline failed. State: FAILED, Error:
> Traceback (most recent call last):
> File "/usr/local/lib/python3.6/site-packages/apache_beam/utils/retry.py",
> line 246, in wrapper
> sleep_interval = next(retry_intervals)
> StopIteration
> During handling of the above exception, another exception occurred:
> Traceback (most recent call last):
> File
> "/usr/local/lib/python3.6/site-packages/dataflow_worker/batchworker.py", line
> 647, in do_work
> work_executor.execute()
> File "/usr/local/lib/python3.6/site-packages/dataflow_worker/executor.py",
> line 226, in execute
> self._split_task)
> File "/usr/local/lib/python3.6/site-packages/dataflow_worker/executor.py",
> line 234, in _perform_source_split_considering_api_limits
> desired_bundle_size)
> File "/usr/local/lib/python3.6/site-packages/dataflow_worker/executor.py",
> line 271, in _perform_source_split
> for split in source.split(desired_bundle_size):
> File
> "/usr/local/lib/python3.6/site-packages/apache_beam/io/gcp/bigquery.py", line
> 698, in split
> self.table_reference = self._execute_query(bq)
> File
> "/usr/local/lib/python3.6/site-packages/apache_beam/options/value_provider.py",
> line 135, in _f
> return fnc(self, *args, **kwargs)
> File
> "/usr/local/lib/python3.6/site-packages/apache_beam/io/gcp/bigquery.py", line
> 744, in _execute_query
> job_labels=self.bigquery_job_labels)
> File "/usr/local/lib/python3.6/site-packages/apache_beam/utils/retry.py",
> line 249, in wrapper
> raise_with_traceback(exn, exn_traceback)
> File "/usr/local/lib/python3.6/site-packages/future/utils/__init__.py",
> line 446, in raise_with_traceback
> raise exc.with_traceback(traceback)
> File "/usr/local/lib/python3.6/site-packages/apache_beam/utils/retry.py",
> line 236, in wrapper
> return fun(*args, **kwargs)
> File
> "/usr/local/lib/python3.6/site-packages/apache_beam/io/gcp/bigquery_tools.py",
> line 415, in _start_query_job
> labels=job_labels or {},
> File
> "/usr/local/lib/python3.6/site-packages/apitools/base/protorpclite/messages.py",
> line 791, in __init__
> setattr(self, name, value)
> File
> "/usr/local/lib/python3.6/site-packages/apitools/base/protorpclite/messages.py",
> line 973, in __setattr__
> object.__setattr__(self, name, value)
> File
> "/usr/local/lib/python3.6/site-packages/apitools/base/protorpclite/messages.py",
> line 1651, in __set__
> value = t(**value)
> File
> "/usr/local/lib/python3.6/site-packages/apitools/base/protorpclite/messages.py",
> line 791, in __init__
> setattr(self, name, value)
> File
> "/usr/local/lib/python3.6/site-packages/apitools/base/protorpclite/messages.py",
> line 976, in __setattr__
> "to message %s" % (name, type(self).__name__))
> AttributeError: May not assign arbitrary value owner to message LabelsValue
--
This message was sent by Atlassian Jira
(v8.3.4#803005)