See
<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Read_Python/117/display/redirect?page=changes>
Changes:
[Chad Dombrova] [BEAM-7746] Add type checking to coders
[milan.cermak] Adds unit tests for the parse_table_reference function
[noreply] Merge pull request #12918 from [BEAM-10910]: Validate the BigQuery
table
[noreply] [Minor] Typo/grammatical changes (#12849)
[noreply] [BEAM-10960] Fix DropFields does not maintain the original fields
order
[noreply] [BEAM-6103] Enable BQ streaming insert timeouts (#12893)
[noreply] Change when streaming Combine on Flink should be fired (#12931)
[Ismaël Mejía] [BEAM-10759] Uses reader Avro schema to deserialize in KafkaIO
------------------------------------------
[...truncated 62.82 KB...]
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 807, in split
schema, metadata_list = self._export_files(bq)
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 879, in _export_files
include_header=False)
File "/usr/local/lib/python3.7/site-packages/apache_beam/utils/retry.py",
line 242, in wrapper
return fun(*args, **kwargs)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 797, in perform_extract_job
response = self.client.jobs.Insert(request)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py",
line 346, in Insert
upload=upload, upload_config=upload_config)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 604, in __ProcessHttpResponse
http_response, method_config=method_config, request=request)
apitools.base.py.exceptions.HttpBadRequestError: HttpError accessing
<https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/jobs?alt=json>:
response: <{'vary': 'Origin, X-Origin, Referer', 'content-type':
'application/json; charset=UTF-8', 'date': 'Fri, 25 Sep 2020 16:06:14 GMT',
'server': 'ESF', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked', 'status': '400', 'content-length': '267',
'-content-encoding': 'gzip'}>, content <{
"error": {
"code": 400,
"message": "Required parameter is missing",
"errors": [
{
"message": "Required parameter is missing",
"domain": "global",
"reason": "required"
}
],
"status": "INVALID_ARGUMENT"
}
}
>
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:20.070Z:
JOB_MESSAGE_ERROR: Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/dataflow_****/batch****.py",
line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
226, in execute
self._split_task)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
234, in _perform_source_split_considering_api_limits
desired_bundle_size)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
271, in _perform_source_split
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 807, in split
schema, metadata_list = self._export_files(bq)
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 879, in _export_files
include_header=False)
File "/usr/local/lib/python3.7/site-packages/apache_beam/utils/retry.py",
line 242, in wrapper
return fun(*args, **kwargs)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 797, in perform_extract_job
response = self.client.jobs.Insert(request)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py",
line 346, in Insert
upload=upload, upload_config=upload_config)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 604, in __ProcessHttpResponse
http_response, method_config=method_config, request=request)
apitools.base.py.exceptions.HttpBadRequestError: HttpError accessing
<https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/jobs?alt=json>:
response: <{'vary': 'Origin, X-Origin, Referer', 'content-type':
'application/json; charset=UTF-8', 'date': 'Fri, 25 Sep 2020 16:06:18 GMT',
'server': 'ESF', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked', 'status': '400', 'content-length': '267',
'-content-encoding': 'gzip'}>, content <{
"error": {
"code": 400,
"message": "Required parameter is missing",
"errors": [
{
"message": "Required parameter is missing",
"domain": "global",
"reason": "required"
}
],
"status": "INVALID_ARGUMENT"
}
}
>
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:21.076Z:
JOB_MESSAGE_BASIC: Finished operation
assert_that/Create/Read+assert_that/Group/pair_with_0+assert_that/Group/GroupByKey/Reify+assert_that/Group/GroupByKey/Write
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:21.269Z:
JOB_MESSAGE_ERROR: Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/dataflow_****/batch****.py",
line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
226, in execute
self._split_task)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
234, in _perform_source_split_considering_api_limits
desired_bundle_size)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
271, in _perform_source_split
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 807, in split
schema, metadata_list = self._export_files(bq)
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 879, in _export_files
include_header=False)
File "/usr/local/lib/python3.7/site-packages/apache_beam/utils/retry.py",
line 242, in wrapper
return fun(*args, **kwargs)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 797, in perform_extract_job
response = self.client.jobs.Insert(request)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py",
line 346, in Insert
upload=upload, upload_config=upload_config)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 604, in __ProcessHttpResponse
http_response, method_config=method_config, request=request)
apitools.base.py.exceptions.HttpBadRequestError: HttpError accessing
<https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/jobs?alt=json>:
response: <{'vary': 'Origin, X-Origin, Referer', 'content-type':
'application/json; charset=UTF-8', 'date': 'Fri, 25 Sep 2020 16:06:20 GMT',
'server': 'ESF', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked', 'status': '400', 'content-length': '267',
'-content-encoding': 'gzip'}>, content <{
"error": {
"code": 400,
"message": "Required parameter is missing",
"errors": [
{
"message": "Required parameter is missing",
"domain": "global",
"reason": "required"
}
],
"status": "INVALID_ARGUMENT"
}
}
>
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.396Z:
JOB_MESSAGE_ERROR: Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/dataflow_****/batch****.py",
line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
226, in execute
self._split_task)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
234, in _perform_source_split_considering_api_limits
desired_bundle_size)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
271, in _perform_source_split
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 807, in split
schema, metadata_list = self._export_files(bq)
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 879, in _export_files
include_header=False)
File "/usr/local/lib/python3.7/site-packages/apache_beam/utils/retry.py",
line 242, in wrapper
return fun(*args, **kwargs)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 797, in perform_extract_job
response = self.client.jobs.Insert(request)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py",
line 346, in Insert
upload=upload, upload_config=upload_config)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 604, in __ProcessHttpResponse
http_response, method_config=method_config, request=request)
apitools.base.py.exceptions.HttpBadRequestError: HttpError accessing
<https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/jobs?alt=json>:
response: <{'vary': 'Origin, X-Origin, Referer', 'content-type':
'application/json; charset=UTF-8', 'date': 'Fri, 25 Sep 2020 16:06:21 GMT',
'server': 'ESF', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked', 'status': '400', 'content-length': '267',
'-content-encoding': 'gzip'}>, content <{
"error": {
"code": 400,
"message": "Required parameter is missing",
"errors": [
{
"message": "Required parameter is missing",
"domain": "global",
"reason": "required"
}
],
"status": "INVALID_ARGUMENT"
}
}
>
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.603Z:
JOB_MESSAGE_BASIC: Finished operation Read from
BigQuery/ReadFromBigQuery/Read+Read from
BigQuery/ReadFromBigQuery/_PassThroughThenCleanup/ParDo(PassThrough)/ParDo(PassThrough)+Count
messages+Measure
time+Count/CombineGlobally(CountCombineFn)/KeyWithVoid+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey+Count/CombineGlobally(CountCombineFn)/CombinePerKey/Combine/Partial+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey/Reify+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey/Write
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.674Z:
JOB_MESSAGE_DEBUG: Executing failure step failure41
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.721Z:
JOB_MESSAGE_ERROR: Workflow failed. Causes: S02:Read from
BigQuery/ReadFromBigQuery/Read+Read from
BigQuery/ReadFromBigQuery/_PassThroughThenCleanup/ParDo(PassThrough)/ParDo(PassThrough)+Count
messages+Measure
time+Count/CombineGlobally(CountCombineFn)/KeyWithVoid+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey+Count/CombineGlobally(CountCombineFn)/CombinePerKey/Combine/Partial+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey/Reify+Count/CombineGlobally(CountCombineFn)/CombinePerKey/GroupByKey/Write
failed., Internal Issue (4271b052cbf527e7): 63963027:24514
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.785Z:
JOB_MESSAGE_DETAILED: Cleaning up.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.848Z:
JOB_MESSAGE_DEBUG: Starting **** pool teardown.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:06:23.880Z:
JOB_MESSAGE_BASIC: Stopping **** pool...
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:07:16.623Z:
JOB_MESSAGE_DETAILED: Autoscaling: Resized **** pool from 5 to 0.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:07:16.670Z:
JOB_MESSAGE_BASIC: Worker pool stopped.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-09-25T16:07:16.750Z:
JOB_MESSAGE_DEBUG: Tearing down pending resources...
INFO:apache_beam.runners.dataflow.dataflow_runner:Job
2020-09-25_09_00_47-12719961137211274084 is in state JOB_STATE_FAILED
Traceback (most recent call last):
File "/usr/lib/python3.7/runpy.py", line 193, in _run_module_as_main
"__main__", mod_spec)
File "/usr/lib/python3.7/runpy.py", line 85, in _run_code
exec(code, run_globals)
File
"<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Read_Python/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_perf_test.py";,>
line 139, in <module>
BigQueryReadPerfTest().run()
File
"<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Read_Python/ws/src/sdks/python/apache_beam/testing/load_tests/load_test.py";,>
line 152, in run
self.result.wait_until_finish(duration=self.timeout_ms)
File
"<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Read_Python/ws/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py";,>
line 1650, in wait_until_finish
self)
apache_beam.runners.dataflow.dataflow_runner.DataflowRuntimeException: Dataflow
pipeline failed. State: FAILED, Error:
Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/dataflow_****/batch****.py",
line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
226, in execute
self._split_task)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
234, in _perform_source_split_considering_api_limits
desired_bundle_size)
File "/usr/local/lib/python3.7/site-packages/dataflow_****/executor.py", line
271, in _perform_source_split
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 807, in split
schema, metadata_list = self._export_files(bq)
File "/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery.py",
line 879, in _export_files
include_header=False)
File "/usr/local/lib/python3.7/site-packages/apache_beam/utils/retry.py",
line 242, in wrapper
return fun(*args, **kwargs)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 797, in perform_extract_job
response = self.client.jobs.Insert(request)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py",
line 346, in Insert
upload=upload, upload_config=upload_config)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.7/site-packages/apitools/base/py/base_api.py",
line 604, in __ProcessHttpResponse
http_response, method_config=method_config, request=request)
apitools.base.py.exceptions.HttpBadRequestError: HttpError accessing
<https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/jobs?alt=json>:
response: <{'vary': 'Origin, X-Origin, Referer', 'content-type':
'application/json; charset=UTF-8', 'date': 'Fri, 25 Sep 2020 16:06:21 GMT',
'server': 'ESF', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked', 'status': '400', 'content-length': '267',
'-content-encoding': 'gzip'}>, content <{
"error": {
"code": 400,
"message": "Required parameter is missing",
"errors": [
{
"message": "Required parameter is missing",
"domain": "global",
"reason": "required"
}
],
"status": "INVALID_ARGUMENT"
}
}
>
> Task :sdks:python:apache_beam:testing:load_tests:run FAILED
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Read_Python/ws/src/sdks/python/apache_beam/testing/load_tests/build.gradle'>
line: 58
* What went wrong:
Execution failed for task ':sdks:python:apache_beam:testing:load_tests:run'.
> error occurred
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/6.6.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8m 13s
5 actionable tasks: 5 executed
Publishing build scan...
https://gradle.com/s/toamca3ywccju
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
