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/07 20:05:47 UTC
Build failed in Jenkins: beam_PostCommit_Python_Verify #2678
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2678/display/redirect?page=changes>
Changes:
[klk] Reject stateful ParDo if coder not KvCoder with deterministic key coder
------------------------------------------
[...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_1499457567336",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T19:59:28.527969Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_12_59_28-1687981095104976617'
location: u'global'
name: u'beamapp-jenkins-0707195927-369563'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_12_59_28-1687981095104976617]
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_12_59_28-1687981095104976617
root: INFO: Job 2017-07-07_12_59_28-1687981095104976617 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T19:59:28.026Z: JOB_MESSAGE_WARNING: (176ce9dcd94e955a): 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-07T19:59:30.236Z: JOB_MESSAGE_DETAILED: (22a7eccfbba6499c): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T19:59:31.250Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64f82): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T19:59:31.252Z: JOB_MESSAGE_DETAILED: (22a7eccfbba644ec): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T19:59:31.257Z: JOB_MESSAGE_DEBUG: (22a7eccfbba64fc0): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T19:59:31.367Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64d49): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T19:59:31.369Z: JOB_MESSAGE_DETAILED: (22a7eccfbba642b3): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T19:59:31.372Z: JOB_MESSAGE_DETAILED: (22a7eccfbba6481d): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T19:59:31.376Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64d87): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T19:59:31.378Z: JOB_MESSAGE_DETAILED: (22a7eccfbba642f1): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T19:59:31.381Z: JOB_MESSAGE_DETAILED: (22a7eccfbba6485b): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T19:59:31.383Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64dc5): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T19:59:31.386Z: JOB_MESSAGE_DETAILED: (22a7eccfbba6432f): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T19:59:31.388Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64899): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T19:59:31.419Z: JOB_MESSAGE_DEBUG: (22a7eccfbba64efb): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T19:59:31.421Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64465): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T19:59:31.423Z: JOB_MESSAGE_DEBUG: (22a7eccfbba649cf): Adding workflow start and stop steps.
root: INFO: 2017-07-07T19:59:31.426Z: JOB_MESSAGE_DEBUG: (22a7eccfbba64f39): Assigning stage ids.
root: INFO: 2017-07-07T19:59:31.472Z: JOB_MESSAGE_DEBUG: (d66c8306272f498e): Executing wait step start22
root: INFO: 2017-07-07T19:59:31.486Z: JOB_MESSAGE_BASIC: (81c4fea6afe0ffc): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T19:59:31.689Z: JOB_MESSAGE_DEBUG: (f387325f70f4e654): Starting worker pool setup.
root: INFO: 2017-07-07T19:59:31.691Z: JOB_MESSAGE_BASIC: (f387325f70f4e1ca): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T19:59:31.710Z: JOB_MESSAGE_DEBUG: (d66c8306272f464b): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T19:59:31.723Z: JOB_MESSAGE_BASIC: (81c4fea6afe0302): 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-07T19:59:32.642Z: JOB_MESSAGE_BASIC: (e50d82b5db65d5b9): BigQuery export job "dataflow_job_16504991926964310263" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_16504991926964310263".
root: INFO: 2017-07-07T20:00:03.172Z: JOB_MESSAGE_DETAILED: (e50d82b5db65d8c1): BigQuery export job progress: "dataflow_job_16504991926964310263" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T20:00:03.175Z: JOB_MESSAGE_BASIC: (e50d82b5db65dd83): BigQuery export job finished: "dataflow_job_16504991926964310263"
root: INFO: 2017-07-07T20:01:26.700Z: JOB_MESSAGE_DETAILED: (b7b0a8f9e33ab008): Workers have started successfully.
root: INFO: 2017-07-07T20:02:54.596Z: JOB_MESSAGE_BASIC: (a8ff4bd95682471f): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T20:02:54.622Z: JOB_MESSAGE_BASIC: (81c4fea6afe0da4): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T20:03:06.374Z: JOB_MESSAGE_BASIC: (a8ff4bd956824887): Executing BigQuery import job "dataflow_job_792443445289276264". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_792443445289276264".
root: INFO: 2017-07-07T20:03:17.337Z: JOB_MESSAGE_BASIC: (a8ff4bd956824568): BigQuery import job "dataflow_job_792443445289276264" done.
root: INFO: 2017-07-07T20:03:18.185Z: JOB_MESSAGE_DEBUG: (a8ff4bd9568246d0): Executing success step success20
root: INFO: 2017-07-07T20:03:18.268Z: JOB_MESSAGE_DETAILED: (22a7eccfbba64a4b): Cleaning up.
root: INFO: 2017-07-07T20:03:18.271Z: JOB_MESSAGE_DEBUG: (22a7eccfbba64fb5): Starting worker pool teardown.
root: INFO: 2017-07-07T20:03:18.273Z: JOB_MESSAGE_BASIC: (22a7eccfbba6451f): Stopping worker pool...
root: INFO: 2017-07-07T20:04:38.280Z: JOB_MESSAGE_BASIC: (22a7eccfbba64d3e): Worker pool stopped.
root: INFO: 2017-07-07T20:04:38.312Z: JOB_MESSAGE_DEBUG: (22a7eccfbba64d7c): Tearing down pending resources...
root: INFO: Job 2017-07-07_12_59_28-1687981095104976617 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.04009487903 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 8.86948488223 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.3850762073 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 20.5771292426 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 378.108s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_12_59_28-1687981095104976617?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_12_59_28-7163681687297497905?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@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
Build failed in Jenkins: beam_PostCommit_Python_Verify #2681
Posted by Apache Jenkins Server <je...@builds.apache.org>.
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
Build failed in Jenkins: beam_PostCommit_Python_Verify #2680
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2680/display/redirect>
------------------------------------------
[...truncated 584.04 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_1499465637109",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T22:13:58.369258Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_15_13_57-15272081972613839378'
location: u'global'
name: u'beamapp-jenkins-0707221357-141548'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_15_13_57-15272081972613839378]
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_15_13_57-15272081972613839378
root: INFO: Job 2017-07-07_15_13_57-15272081972613839378 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T22:13:57.773Z: JOB_MESSAGE_WARNING: (d3f155a39e4b768d): 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-07T22:13:59.935Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62bd3): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T22:14:00.880Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62565): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T22:14:00.883Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede626c3): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T22:14:00.887Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede6297f): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T22:14:00.981Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62cea): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T22:14:00.983Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62e48): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T22:14:00.985Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62fa6): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T22:14:00.988Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62104): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T22:14:00.990Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62262): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T22:14:00.993Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede623c0): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T22:14:00.995Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede6251e): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T22:14:00.998Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede6267c): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T22:14:01Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede627da): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T22:14:01.032Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede629a0): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T22:14:01.034Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62afe): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T22:14:01.036Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede62c5c): Adding workflow start and stop steps.
root: INFO: 2017-07-07T22:14:01.039Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede62dba): Assigning stage ids.
root: INFO: 2017-07-07T22:14:01.115Z: JOB_MESSAGE_DEBUG: (8c9bdac62ee23c05): Executing wait step start22
root: INFO: 2017-07-07T22:14:01.135Z: JOB_MESSAGE_BASIC: (6fc3202b25eed0e): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T22:14:01.339Z: JOB_MESSAGE_DEBUG: (6f7e613aba63c57): Starting worker pool setup.
root: INFO: 2017-07-07T22:14:01.342Z: JOB_MESSAGE_BASIC: (6f7e613aba6316d): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T22:14:01.362Z: JOB_MESSAGE_DEBUG: (8c9bdac62ee238e8): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T22:14:01.388Z: JOB_MESSAGE_BASIC: (6fc3202b25eee91): 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-07T22:14:04.558Z: JOB_MESSAGE_BASIC: (1dd3812b4bfcef67): BigQuery export job "dataflow_job_2149203470144302381" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_2149203470144302381".
root: INFO: 2017-07-07T22:14:35.102Z: JOB_MESSAGE_DETAILED: (199d7829143b855c): BigQuery export job progress: "dataflow_job_2149203470144302381" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T22:14:35.106Z: JOB_MESSAGE_BASIC: (199d7829143b82ca): BigQuery export job finished: "dataflow_job_2149203470144302381"
root: INFO: 2017-07-07T22:16:07.534Z: JOB_MESSAGE_DETAILED: (6015cc8b42d5cd26): Workers have started successfully.
root: INFO: 2017-07-07T22:17:50.869Z: JOB_MESSAGE_BASIC: (8c9bdac62ee23aac): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T22:17:50.886Z: JOB_MESSAGE_BASIC: (6fc3202b25ee095): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T22:18:04.031Z: JOB_MESSAGE_BASIC: (8c9bdac62ee2331d): Executing BigQuery import job "dataflow_job_11421620605950578617". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_11421620605950578617".
root: INFO: 2017-07-07T22:18:15.023Z: JOB_MESSAGE_BASIC: (8c9bdac62ee235c7): BigQuery import job "dataflow_job_11421620605950578617" done.
root: INFO: 2017-07-07T22:18:16.082Z: JOB_MESSAGE_DEBUG: (8c9bdac62ee233ff): Executing success step success20
root: INFO: 2017-07-07T22:18:16.167Z: JOB_MESSAGE_DETAILED: (8fc8dc95ede62490): Cleaning up.
root: INFO: 2017-07-07T22:18:16.171Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede625ee): Starting worker pool teardown.
root: INFO: 2017-07-07T22:18:16.174Z: JOB_MESSAGE_BASIC: (8fc8dc95ede6274c): Stopping worker pool...
root: INFO: 2017-07-07T22:19:31.181Z: JOB_MESSAGE_BASIC: (8fc8dc95ede62959): Worker pool stopped.
root: INFO: 2017-07-07T22:19:31.225Z: JOB_MESSAGE_DEBUG: (8fc8dc95ede62e22): Tearing down pending resources...
root: INFO: Job 2017-07-07_15_13_57-15272081972613839378 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.3381427263 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 8.35430167358 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 13.7074826127 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 25.0774672812 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 397.301s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_15_13_57-15272081972613839378?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_15_13_58-14788553934577989425?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@google.com
Build failed in Jenkins: beam_PostCommit_Python_Verify #2679
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2679/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-1347] Rename DoFnRunnerFactory to FnApiDoFnRunner.
[lcwik] [BEAM-1347] Add DoFnRunner specific to Fn Api.
------------------------------------------
[...truncated 585.94 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_1499462798003",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T21:26:39.146663Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_14_26_38-9518512978329702294'
location: u'global'
name: u'beamapp-jenkins-0707212638-037455'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_14_26_38-9518512978329702294]
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_14_26_38-9518512978329702294
root: INFO: Job 2017-07-07_14_26_38-9518512978329702294 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T21:26:38.592Z: JOB_MESSAGE_WARNING: (84188d1f5f498051): 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-07T21:26:40.976Z: JOB_MESSAGE_DETAILED: (d128e81f7645d7b0): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T21:26:42.006Z: JOB_MESSAGE_DETAILED: (d128e81f7645d2a6): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T21:26:42.009Z: JOB_MESSAGE_DETAILED: (d128e81f7645d680): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T21:26:42.019Z: JOB_MESSAGE_DEBUG: (d128e81f7645de34): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T21:26:42.087Z: JOB_MESSAGE_DETAILED: (d128e81f7645d7d5): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T21:26:42.090Z: JOB_MESSAGE_DETAILED: (d128e81f7645dbaf): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T21:26:42.093Z: JOB_MESSAGE_DETAILED: (d128e81f7645df89): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T21:26:42.095Z: JOB_MESSAGE_DETAILED: (d128e81f7645d363): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T21:26:42.099Z: JOB_MESSAGE_DETAILED: (d128e81f7645d73d): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T21:26:42.102Z: JOB_MESSAGE_DETAILED: (d128e81f7645db17): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T21:26:42.105Z: JOB_MESSAGE_DETAILED: (d128e81f7645def1): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T21:26:42.108Z: JOB_MESSAGE_DETAILED: (d128e81f7645d2cb): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T21:26:42.112Z: JOB_MESSAGE_DETAILED: (d128e81f7645d6a5): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T21:26:42.147Z: JOB_MESSAGE_DEBUG: (d128e81f7645d8b7): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T21:26:42.149Z: JOB_MESSAGE_DETAILED: (d128e81f7645dc91): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T21:26:42.153Z: JOB_MESSAGE_DEBUG: (d128e81f7645d06b): Adding workflow start and stop steps.
root: INFO: 2017-07-07T21:26:42.157Z: JOB_MESSAGE_DEBUG: (d128e81f7645d445): Assigning stage ids.
root: INFO: 2017-07-07T21:26:42.208Z: JOB_MESSAGE_DEBUG: (bee2f596c3985e35): Executing wait step start22
root: INFO: 2017-07-07T21:26:42.223Z: JOB_MESSAGE_BASIC: (554467f1a24455f6): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T21:26:42.427Z: JOB_MESSAGE_DEBUG: (71ac8f82b39cb047): Starting worker pool setup.
root: INFO: 2017-07-07T21:26:42.430Z: JOB_MESSAGE_BASIC: (71ac8f82b39cb731): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T21:26:42.452Z: JOB_MESSAGE_DEBUG: (554467f1a2445094): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T21:26:42.475Z: JOB_MESSAGE_BASIC: (bee2f596c398528c): 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-07T21:26:43.444Z: JOB_MESSAGE_BASIC: (87066e54aa8083dc): BigQuery export job "dataflow_job_9729585354897395186" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_9729585354897395186".
root: INFO: 2017-07-07T21:27:13.836Z: JOB_MESSAGE_DETAILED: (d70ed2c3096f9bbf): BigQuery export job progress: "dataflow_job_9729585354897395186" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T21:27:13.840Z: JOB_MESSAGE_BASIC: (d70ed2c3096f9d4d): BigQuery export job finished: "dataflow_job_9729585354897395186"
root: INFO: 2017-07-07T21:27:44.268Z: JOB_MESSAGE_DETAILED: (9e43dcc356b62a31): Workers have started successfully.
root: INFO: 2017-07-07T21:30:32.143Z: JOB_MESSAGE_BASIC: (e729033c1560fd30): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T21:30:32.174Z: JOB_MESSAGE_BASIC: (bee2f596c39851e6): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T21:30:44.182Z: JOB_MESSAGE_BASIC: (bbc92120fe60618b): Executing BigQuery import job "dataflow_job_2947317239846759963". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_2947317239846759963".
root: INFO: 2017-07-07T21:30:55.228Z: JOB_MESSAGE_BASIC: (bbc92120fe606b46): BigQuery import job "dataflow_job_2947317239846759963" done.
root: INFO: 2017-07-07T21:30:55.704Z: JOB_MESSAGE_DEBUG: (bbc92120fe60613e): Executing success step success20
root: INFO: 2017-07-07T21:30:55.797Z: JOB_MESSAGE_DETAILED: (d128e81f7645d787): Cleaning up.
root: INFO: 2017-07-07T21:30:55.801Z: JOB_MESSAGE_DEBUG: (d128e81f7645db61): Starting worker pool teardown.
root: INFO: 2017-07-07T21:30:55.804Z: JOB_MESSAGE_BASIC: (d128e81f7645df3b): Stopping worker pool...
root: INFO: 2017-07-07T21:32:10.812Z: JOB_MESSAGE_BASIC: (d128e81f7645d502): Worker pool stopped.
root: INFO: 2017-07-07T21:32:10.831Z: JOB_MESSAGE_DEBUG: (d128e81f7645d090): Tearing down pending resources...
root: INFO: Job 2017-07-07_14_26_38-9518512978329702294 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 4.95570980879 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.01084709813 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 13.4329654714 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 30.191627932 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 401.892s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_14_26_38-9518512978329702294?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_14_26_39-148118149092554851?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@google.com