You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/07/08 02:27:24 UTC
Build failed in Jenkins: beam_PostCommit_Python_Verify #2681
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2681/display/redirect?page=changes>
Changes:
[valentyn] Set the type of batch jobs to FNAPI_BATCH when beam_fn_api experiment is
------------------------------------------
[...truncated 584.96 KB...]
{
"kind": "CombineValues",
"name": "s4",
"properties": {
"display_data": [],
"encoding": {
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "out",
"user_name": "monthly count/Combine.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s3"
},
"serialized_fn": "<string of 236 bytes>",
"user_name": "monthly count/Combine"
}
},
{
"kind": "ParallelDo",
"name": "s5",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "<lambda>"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
}
],
"non_parallel_inputs": {},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "out",
"user_name": "format.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s4"
},
"serialized_fn": "<string of 1036 bytes>",
"user_name": "format"
}
},
{
"kind": "ParallelWrite",
"name": "s6",
"properties": {
"create_disposition": "CREATE_IF_NEEDED",
"dataset": "BigQueryTornadoesIT",
"display_data": [],
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "RowAsDictJsonCoder$eNprYEpOLEhMzkiNT0pNzNXLzNdLTy7QS8pMLyxNLarkCsovdyx2yUwu8SrOz3POT0kt4ipk0GwsZKwtZErSAwCu1BVY",
"component_encodings": []
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"format": "bigquery",
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s5"
},
"schema": "{\"fields\": [{\"type\": \"INTEGER\", \"name\": \"month\", \"mode\": \"NULLABLE\"}, {\"type\": \"INTEGER\", \"name\": \"tornado_count\", \"mode\": \"NULLABLE\"}]}",
"table": "monthly_tornadoes_1499480399442",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-08T02:20:00.848379Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_19_20_00-7458708861261426274'
location: u'global'
name: u'beamapp-jenkins-0708021959-479653'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_19_20_00-7458708861261426274]
root: INFO: To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-07-07_19_20_00-7458708861261426274
root: INFO: Job 2017-07-07_19_20_00-7458708861261426274 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-08T02:20:00.324Z: JOB_MESSAGE_WARNING: (6782a830fe8baa61): Setting the number of workers (1) disables autoscaling for this job. If you are trying to cap autoscaling, consider only setting max_num_workers. If you want to disable autoscaling altogether, the documented way is to explicitly use autoscalingAlgorithm=NONE.
root: INFO: 2017-07-08T02:20:02.326Z: JOB_MESSAGE_DETAILED: (a01b1068bebde843): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-08T02:20:03.182Z: JOB_MESSAGE_DETAILED: (a01b1068bebde40d): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-08T02:20:03.184Z: JOB_MESSAGE_DETAILED: (a01b1068bebde373): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-08T02:20:03.189Z: JOB_MESSAGE_DEBUG: (a01b1068bebde23f): Annotating graph with Autotuner information.
root: INFO: 2017-07-08T02:20:03.295Z: JOB_MESSAGE_DETAILED: (a01b1068bebde0be): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-08T02:20:03.297Z: JOB_MESSAGE_DETAILED: (a01b1068bebde024): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-08T02:20:03.299Z: JOB_MESSAGE_DETAILED: (a01b1068bebdef8a): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-08T02:20:03.302Z: JOB_MESSAGE_DETAILED: (a01b1068bebdeef0): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-08T02:20:03.303Z: JOB_MESSAGE_DETAILED: (a01b1068bebdee56): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-08T02:20:03.305Z: JOB_MESSAGE_DETAILED: (a01b1068bebdedbc): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-08T02:20:03.308Z: JOB_MESSAGE_DETAILED: (a01b1068bebded22): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-08T02:20:03.310Z: JOB_MESSAGE_DETAILED: (a01b1068bebdec88): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-08T02:20:03.312Z: JOB_MESSAGE_DETAILED: (a01b1068bebdebee): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-08T02:20:03.340Z: JOB_MESSAGE_DEBUG: (a01b1068bebde41c): Workflow config is missing a default resource spec.
root: INFO: 2017-07-08T02:20:03.342Z: JOB_MESSAGE_DETAILED: (a01b1068bebde382): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-08T02:20:03.344Z: JOB_MESSAGE_DEBUG: (a01b1068bebde2e8): Adding workflow start and stop steps.
root: INFO: 2017-07-08T02:20:03.346Z: JOB_MESSAGE_DEBUG: (a01b1068bebde24e): Assigning stage ids.
root: INFO: 2017-07-08T02:20:03.391Z: JOB_MESSAGE_DEBUG: (1e88070e3ee11b50): Executing wait step start22
root: INFO: 2017-07-08T02:20:03.402Z: JOB_MESSAGE_BASIC: (197690769a86745): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-08T02:20:03.605Z: JOB_MESSAGE_DEBUG: (916084f85e9661d2): Starting worker pool setup.
root: INFO: 2017-07-08T02:20:03.607Z: JOB_MESSAGE_BASIC: (916084f85e9664f0): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-08T02:20:03.624Z: JOB_MESSAGE_DEBUG: (1e88070e3ee117bb): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-08T02:20:03.639Z: JOB_MESSAGE_BASIC: (1e88070e3ee11f84): Executing operation read+months with tornadoes+monthly count/GroupByKey+monthly count/Combine/Partial+monthly count/GroupByKey/Reify+monthly count/GroupByKey/Write
root: INFO: 2017-07-08T02:20:04.532Z: JOB_MESSAGE_BASIC: (c2cd4159f0a6f3b5): BigQuery export job "dataflow_job_14036947468129071603" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_14036947468129071603".
root: INFO: 2017-07-08T02:20:34.858Z: JOB_MESSAGE_DETAILED: (34f01597d65714f8): BigQuery export job progress: "dataflow_job_14036947468129071603" observed total of 1 exported files thus far.
root: INFO: 2017-07-08T02:20:34.861Z: JOB_MESSAGE_BASIC: (34f01597d6571df6): BigQuery export job finished: "dataflow_job_14036947468129071603"
root: INFO: 2017-07-08T02:22:06.079Z: JOB_MESSAGE_DETAILED: (1f15610be1577591): Workers have started successfully.
root: INFO: 2017-07-08T02:23:51.480Z: JOB_MESSAGE_BASIC: (86e998de4c42867): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-08T02:23:51.495Z: JOB_MESSAGE_BASIC: (1e88070e3ee113b8): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-08T02:24:03.971Z: JOB_MESSAGE_BASIC: (86e998de4c424bf): Executing BigQuery import job "dataflow_job_14136605735902663374". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_14136605735902663374".
root: INFO: 2017-07-08T02:24:14.969Z: JOB_MESSAGE_BASIC: (86e998de4c42e01): BigQuery import job "dataflow_job_14136605735902663374" done.
root: INFO: 2017-07-08T02:24:15.688Z: JOB_MESSAGE_DEBUG: (86e998de4c42a59): Executing success step success20
root: INFO: 2017-07-08T02:24:15.781Z: JOB_MESSAGE_DETAILED: (a01b1068bebdef4c): Cleaning up.
root: INFO: 2017-07-08T02:24:15.784Z: JOB_MESSAGE_DEBUG: (a01b1068bebdeeb2): Starting worker pool teardown.
root: INFO: 2017-07-08T02:24:15.786Z: JOB_MESSAGE_BASIC: (a01b1068bebdee18): Stopping worker pool...
root: INFO: 2017-07-08T02:25:30.793Z: JOB_MESSAGE_BASIC: (a01b1068bebded31): Worker pool stopped.
root: INFO: 2017-07-08T02:25:30.863Z: JOB_MESSAGE_DEBUG: (a01b1068bebdeb16): Tearing down pending resources...
root: INFO: Job 2017-07-07_19_20_00-7458708861261426274 is in state JOB_STATE_DONE
root: INFO: Start verify Bigquery data.
google.auth.transport._http_client: DEBUG: Making request: GET http://169.254.169.254
google.auth.transport._http_client: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/project/project-id
google_auth_httplib2: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/default/?recursive=true
google_auth_httplib2: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/844138762903-compute@developer.gserviceaccount.com/token
root: WARNING: Retry with exponential backoff: waiting for 3.41044804992 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 7.04355801158 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 19.4738155256 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 28.6380548018 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 2 tests in 441.080s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_19_20_00-14323345255816151022?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_19_20_00-7458708861261426274?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@google.com
Not sending mail to unregistered user valentyn@google.com
Jenkins build is back to normal : beam_PostCommit_Python_Verify
#2683
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2683/display/redirect>
Build failed in Jenkins: beam_PostCommit_Python_Verify #2682
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2682/display/redirect>
------------------------------------------
[...truncated 584.05 KB...]
{
"kind": "CombineValues",
"name": "s4",
"properties": {
"display_data": [],
"encoding": {
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "out",
"user_name": "monthly count/Combine.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s3"
},
"serialized_fn": "<string of 236 bytes>",
"user_name": "monthly count/Combine"
}
},
{
"kind": "ParallelDo",
"name": "s5",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "<lambda>"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
}
],
"non_parallel_inputs": {},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": [
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
},
{
"@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/",
"component_encodings": []
}
],
"is_pair_like": true
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "out",
"user_name": "format.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s4"
},
"serialized_fn": "<string of 1036 bytes>",
"user_name": "format"
}
},
{
"kind": "ParallelWrite",
"name": "s6",
"properties": {
"create_disposition": "CREATE_IF_NEEDED",
"dataset": "BigQueryTornadoesIT",
"display_data": [],
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type": "RowAsDictJsonCoder$eNprYEpOLEhMzkiNT0pNzNXLzNdLTy7QS8pMLyxNLarkCsovdyx2yUwu8SrOz3POT0kt4ipk0GwsZKwtZErSAwCu1BVY",
"component_encodings": []
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"format": "bigquery",
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s5"
},
"schema": "{\"fields\": [{\"type\": \"INTEGER\", \"name\": \"month\", \"mode\": \"NULLABLE\"}, {\"type\": \"INTEGER\", \"name\": \"tornado_count\", \"mode\": \"NULLABLE\"}]}",
"table": "monthly_tornadoes_1499485132858",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-08T03:38:54.216713Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_20_38_53-5390488971089969585'
location: u'global'
name: u'beamapp-jenkins-0708033852-891389'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_20_38_53-5390488971089969585]
root: INFO: To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-07-07_20_38_53-5390488971089969585
root: INFO: Job 2017-07-07_20_38_53-5390488971089969585 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-08T03:38:53.521Z: JOB_MESSAGE_WARNING: (4acedd28bf7a8fb0): Setting the number of workers (1) disables autoscaling for this job. If you are trying to cap autoscaling, consider only setting max_num_workers. If you want to disable autoscaling altogether, the documented way is to explicitly use autoscalingAlgorithm=NONE.
root: INFO: 2017-07-08T03:38:56.205Z: JOB_MESSAGE_DETAILED: (17c67dd92825197f): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-08T03:38:58.040Z: JOB_MESSAGE_DETAILED: (17c67dd928251db1): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-08T03:38:58.043Z: JOB_MESSAGE_DETAILED: (17c67dd92825176f): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-08T03:38:58.049Z: JOB_MESSAGE_DEBUG: (17c67dd928251aeb): Annotating graph with Autotuner information.
root: INFO: 2017-07-08T03:38:58.137Z: JOB_MESSAGE_DETAILED: (17c67dd928251b46): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-08T03:38:58.140Z: JOB_MESSAGE_DETAILED: (17c67dd928251504): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-08T03:38:58.143Z: JOB_MESSAGE_DETAILED: (17c67dd928251ec2): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-08T03:38:58.145Z: JOB_MESSAGE_DETAILED: (17c67dd928251880): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-08T03:38:58.148Z: JOB_MESSAGE_DETAILED: (17c67dd92825123e): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-08T03:38:58.150Z: JOB_MESSAGE_DETAILED: (17c67dd928251bfc): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-08T03:38:58.153Z: JOB_MESSAGE_DETAILED: (17c67dd9282515ba): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-08T03:38:58.155Z: JOB_MESSAGE_DETAILED: (17c67dd928251f78): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-08T03:38:58.158Z: JOB_MESSAGE_DETAILED: (17c67dd928251936): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-08T03:38:58.237Z: JOB_MESSAGE_DEBUG: (17c67dd9282517dc): Workflow config is missing a default resource spec.
root: INFO: 2017-07-08T03:38:58.240Z: JOB_MESSAGE_DETAILED: (17c67dd92825119a): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-08T03:38:58.243Z: JOB_MESSAGE_DEBUG: (17c67dd928251b58): Adding workflow start and stop steps.
root: INFO: 2017-07-08T03:38:58.246Z: JOB_MESSAGE_DEBUG: (17c67dd928251516): Assigning stage ids.
root: INFO: 2017-07-08T03:38:58.340Z: JOB_MESSAGE_DEBUG: (3241c53af0bb97e2): Executing wait step start22
root: INFO: 2017-07-08T03:38:58.363Z: JOB_MESSAGE_BASIC: (22341b7c1d1abbb5): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-08T03:38:58.566Z: JOB_MESSAGE_DEBUG: (d33cb878257dd36d): Starting worker pool setup.
root: INFO: 2017-07-08T03:38:58.568Z: JOB_MESSAGE_BASIC: (d33cb878257ddeb3): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-08T03:38:58.619Z: JOB_MESSAGE_DEBUG: (22341b7c1d1abc0b): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-08T03:38:58.647Z: JOB_MESSAGE_BASIC: (3241c53af0bb93fb): Executing operation read+months with tornadoes+monthly count/GroupByKey+monthly count/Combine/Partial+monthly count/GroupByKey/Reify+monthly count/GroupByKey/Write
root: INFO: 2017-07-08T03:39:03.035Z: JOB_MESSAGE_BASIC: (370e2c4bcf914fc8): BigQuery export job "dataflow_job_3967157025876558294" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_3967157025876558294".
root: INFO: 2017-07-08T03:39:33.451Z: JOB_MESSAGE_DETAILED: (7185caf18c51309b): BigQuery export job progress: "dataflow_job_3967157025876558294" observed total of 1 exported files thus far.
root: INFO: 2017-07-08T03:39:33.453Z: JOB_MESSAGE_BASIC: (7185caf18c51349d): BigQuery export job finished: "dataflow_job_3967157025876558294"
root: INFO: 2017-07-08T03:41:08.643Z: JOB_MESSAGE_DETAILED: (49b8b2bddd3cdc8c): Workers have started successfully.
root: INFO: 2017-07-08T03:42:42.236Z: JOB_MESSAGE_BASIC: (b36e06759b4e19a): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-08T03:42:42.290Z: JOB_MESSAGE_BASIC: (3241c53af0bb9c41): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-08T03:42:52.556Z: JOB_MESSAGE_BASIC: (e2604dc00c379524): Executing BigQuery import job "dataflow_job_12621695178195500154". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_12621695178195500154".
root: INFO: 2017-07-08T03:43:03.454Z: JOB_MESSAGE_BASIC: (e2604dc00c379ed5): BigQuery import job "dataflow_job_12621695178195500154" done.
root: INFO: 2017-07-08T03:43:04.188Z: JOB_MESSAGE_DEBUG: (e2604dc00c3794bd): Executing success step success20
root: INFO: 2017-07-08T03:43:04.270Z: JOB_MESSAGE_DETAILED: (17c67dd9282515cc): Cleaning up.
root: INFO: 2017-07-08T03:43:04.295Z: JOB_MESSAGE_DEBUG: (17c67dd928251f8a): Starting worker pool teardown.
root: INFO: 2017-07-08T03:43:04.301Z: JOB_MESSAGE_BASIC: (17c67dd928251948): Stopping worker pool...
root: INFO: 2017-07-08T03:44:19.328Z: JOB_MESSAGE_BASIC: (17c67dd928251fe5): Worker pool stopped.
root: INFO: 2017-07-08T03:44:19.354Z: JOB_MESSAGE_DEBUG: (17c67dd928251d1f): Tearing down pending resources...
root: INFO: Job 2017-07-07_20_38_53-5390488971089969585 is in state JOB_STATE_DONE
root: INFO: Start verify Bigquery data.
google.auth.transport._http_client: DEBUG: Making request: GET http://169.254.169.254
google.auth.transport._http_client: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/project/project-id
google_auth_httplib2: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/default/?recursive=true
google_auth_httplib2: DEBUG: Making request: GET http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/844138762903-compute@developer.gserviceaccount.com/token
root: WARNING: Retry with exponential backoff: waiting for 3.67831322721 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 6.20006610483 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 18.1116190725 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
root: WARNING: Retry with exponential backoff: waiting for 39.3527133117 seconds before retrying _query_with_retry because we caught exception: ValueError: too many values to unpack
Traceback for above exception (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/utils/retry.py",> line 168, in wrapper
return fun(*args, **kwargs)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py",> line 95, in _query_with_retry
rows, _, page_token = query.fetch_data(page_token=page_token)
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 2 tests in 409.338s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_20_38_53-5390488971089969585?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_20_38_54-793741191671809810?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@google.com
Not sending mail to unregistered user valentyn@google.com