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 10:08:29 UTC
Build failed in Jenkins: beam_PostCommit_Python_Verify #2674
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2674/display/redirect>
------------------------------------------
[...truncated 583.73 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_1499421690328",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T10:01:31.489396Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_03_01_30-7575188608791072258'
location: u'global'
name: u'beamapp-jenkins-0707100130-361771'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_03_01_30-7575188608791072258]
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_03_01_30-7575188608791072258
root: INFO: Job 2017-07-07_03_01_30-7575188608791072258 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T10:01:30.919Z: JOB_MESSAGE_WARNING: (692079e79593c125): 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-07T10:01:33.997Z: JOB_MESSAGE_DETAILED: (7442f2aee29270ea): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T10:01:34.877Z: JOB_MESSAGE_DETAILED: (7442f2aee2927674): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T10:01:34.886Z: JOB_MESSAGE_DETAILED: (7442f2aee2927e1a): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T10:01:34.905Z: JOB_MESSAGE_DEBUG: (7442f2aee2927d66): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T10:01:35.050Z: JOB_MESSAGE_DETAILED: (7442f2aee2927885): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T10:01:35.057Z: JOB_MESSAGE_DETAILED: (7442f2aee292702b): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T10:01:35.066Z: JOB_MESSAGE_DETAILED: (7442f2aee29277d1): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T10:01:35.070Z: JOB_MESSAGE_DETAILED: (7442f2aee2927f77): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T10:01:35.075Z: JOB_MESSAGE_DETAILED: (7442f2aee292771d): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T10:01:35.082Z: JOB_MESSAGE_DETAILED: (7442f2aee2927ec3): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T10:01:35.087Z: JOB_MESSAGE_DETAILED: (7442f2aee2927669): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T10:01:35.093Z: JOB_MESSAGE_DETAILED: (7442f2aee2927e0f): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T10:01:35.105Z: JOB_MESSAGE_DETAILED: (7442f2aee29275b5): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T10:01:35.219Z: JOB_MESSAGE_DEBUG: (7442f2aee2927923): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T10:01:35.223Z: JOB_MESSAGE_DETAILED: (7442f2aee29270c9): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T10:01:35.225Z: JOB_MESSAGE_DEBUG: (7442f2aee292786f): Adding workflow start and stop steps.
root: INFO: 2017-07-07T10:01:35.234Z: JOB_MESSAGE_DEBUG: (7442f2aee2927015): Assigning stage ids.
root: INFO: 2017-07-07T10:01:35.402Z: JOB_MESSAGE_DEBUG: (21f7a61e99dd1e5e): Executing wait step start22
root: INFO: 2017-07-07T10:01:35.435Z: JOB_MESSAGE_BASIC: (bb3b4b140143abf3): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T10:01:35.656Z: JOB_MESSAGE_DEBUG: (39ed8936a734f46): Starting worker pool setup.
root: INFO: 2017-07-07T10:01:35.671Z: JOB_MESSAGE_BASIC: (39ed8936a734340): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T10:01:35.738Z: JOB_MESSAGE_DEBUG: (bb3b4b140143a788): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T10:01:35.785Z: JOB_MESSAGE_BASIC: (bb3b4b140143aec3): 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-07T10:01:36.743Z: JOB_MESSAGE_BASIC: (98e321c0f58ec9ec): BigQuery export job "dataflow_job_11016686226115577278" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_11016686226115577278".
root: INFO: 2017-07-07T10:02:07.121Z: JOB_MESSAGE_DETAILED: (ecd5cf6ae3f10440): BigQuery export job progress: "dataflow_job_11016686226115577278" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T10:02:07.134Z: JOB_MESSAGE_BASIC: (ecd5cf6ae3f1097a): BigQuery export job finished: "dataflow_job_11016686226115577278"
root: INFO: 2017-07-07T10:02:49.404Z: JOB_MESSAGE_DETAILED: (5bb05d66a6d10bdf): Workers have started successfully.
root: INFO: 2017-07-07T10:05:51.104Z: JOB_MESSAGE_BASIC: (b6df36952223bc76): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T10:05:51.208Z: JOB_MESSAGE_BASIC: (b6df36952223bf40): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T10:06:03.452Z: JOB_MESSAGE_BASIC: (bb3b4b140143a30c): Executing BigQuery import job "dataflow_job_10014933176738704996". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_10014933176738704996".
root: INFO: 2017-07-07T10:06:14.517Z: JOB_MESSAGE_BASIC: (bb3b4b140143a01a): BigQuery import job "dataflow_job_10014933176738704996" done.
root: INFO: 2017-07-07T10:06:15.295Z: JOB_MESSAGE_DEBUG: (bb3b4b140143a182): Executing success step success20
root: INFO: 2017-07-07T10:06:15.388Z: JOB_MESSAGE_DETAILED: (7442f2aee2927653): Cleaning up.
root: INFO: 2017-07-07T10:06:15.393Z: JOB_MESSAGE_DEBUG: (7442f2aee2927df9): Starting worker pool teardown.
root: INFO: 2017-07-07T10:06:15.403Z: JOB_MESSAGE_BASIC: (7442f2aee292759f): Stopping worker pool...
root: INFO: 2017-07-07T10:07:20.420Z: JOB_MESSAGE_BASIC: (7442f2aee2927918): Worker pool stopped.
root: INFO: 2017-07-07T10:07:20.526Z: JOB_MESSAGE_DEBUG: (7442f2aee2927bdd): Tearing down pending resources...
root: INFO: Job 2017-07-07_03_01_30-7575188608791072258 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.30559417135 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.10093369536 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 15.7002516578 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 24.2887354609 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 416.244s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_03_01_30-7575188608791072258?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_03_01_31-5215414620118241898?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
Build failed in Jenkins: beam_PostCommit_Python_Verify #2678
Posted by Apache Jenkins Server <je...@builds.apache.org>.
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
Build failed in Jenkins: beam_PostCommit_Python_Verify #2677
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2677/display/redirect?page=changes>
Changes:
[klk] Move DirectRunner knob for suppressing runner-determined sharding out of
------------------------------------------
[...truncated 586.84 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_1499449017775",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T17:36:58.790550Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_10_36_58-10630794781884904388'
location: u'global'
name: u'beamapp-jenkins-0707173657-813211'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_10_36_58-10630794781884904388]
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_10_36_58-10630794781884904388
root: INFO: Job 2017-07-07_10_36_58-10630794781884904388 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T17:36:58.409Z: JOB_MESSAGE_WARNING: (93882b879e53750f): 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-07T17:37:00.288Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0621): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T17:37:01.265Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0d6f): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T17:37:01.267Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0c31): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T17:37:01.272Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b09b5): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T17:37:01.365Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b069a): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T17:37:01.368Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b055c): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T17:37:01.370Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b041e): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T17:37:01.372Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b02e0): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T17:37:01.375Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b01a2): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T17:37:01.379Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0064): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T17:37:01.381Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0f26): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T17:37:01.383Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0de8): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T17:37:01.385Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0caa): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T17:37:01.414Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b0c84): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T17:37:01.416Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0b46): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T17:37:01.419Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b0a08): Adding workflow start and stop steps.
root: INFO: 2017-07-07T17:37:01.421Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b08ca): Assigning stage ids.
root: INFO: 2017-07-07T17:37:01.468Z: JOB_MESSAGE_DEBUG: (a850faff571f0d3e): Executing wait step start22
root: INFO: 2017-07-07T17:37:01.481Z: JOB_MESSAGE_BASIC: (34a5c9734792e608): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T17:37:01.684Z: JOB_MESSAGE_DEBUG: (c07123968db3370e): Starting worker pool setup.
root: INFO: 2017-07-07T17:37:01.687Z: JOB_MESSAGE_BASIC: (c07123968db33fbc): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T17:37:01.702Z: JOB_MESSAGE_DEBUG: (a850faff571f0f69): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T17:37:01.716Z: JOB_MESSAGE_BASIC: (34a5c9734792e237): 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-07T17:37:02.832Z: JOB_MESSAGE_BASIC: (dd493373e3a738b): BigQuery export job "dataflow_job_996583283032227157" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_996583283032227157".
root: INFO: 2017-07-07T17:37:33.356Z: JOB_MESSAGE_DETAILED: (287532e3ca5bbbfb): BigQuery export job progress: "dataflow_job_996583283032227157" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T17:37:33.359Z: JOB_MESSAGE_BASIC: (287532e3ca5bbe19): BigQuery export job finished: "dataflow_job_996583283032227157"
root: INFO: 2017-07-07T17:38:09.725Z: JOB_MESSAGE_DETAILED: (a3db53a2f6be2e1f): Workers have started successfully.
root: INFO: 2017-07-07T17:41:19.152Z: JOB_MESSAGE_BASIC: (abde8911d4d725d9): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T17:41:19.167Z: JOB_MESSAGE_BASIC: (34a5c9734792e7cb): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T17:41:30.939Z: JOB_MESSAGE_BASIC: (abde8911d4d72442): Executing BigQuery import job "dataflow_job_8103192811291073233". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_8103192811291073233".
root: INFO: 2017-07-07T17:41:41.886Z: JOB_MESSAGE_BASIC: (abde8911d4d72e8d): BigQuery import job "dataflow_job_8103192811291073233" done.
root: INFO: 2017-07-07T17:41:43.060Z: JOB_MESSAGE_DEBUG: (abde8911d4d72f05): Executing success step success20
root: INFO: 2017-07-07T17:41:43.156Z: JOB_MESSAGE_DETAILED: (cbfa3ed77c7b0294): Cleaning up.
root: INFO: 2017-07-07T17:41:43.159Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b0156): Starting worker pool teardown.
root: INFO: 2017-07-07T17:41:43.161Z: JOB_MESSAGE_BASIC: (cbfa3ed77c7b0018): Stopping worker pool...
root: INFO: 2017-07-07T17:42:48.168Z: JOB_MESSAGE_BASIC: (cbfa3ed77c7b0e3b): Worker pool stopped.
root: INFO: 2017-07-07T17:42:48.223Z: JOB_MESSAGE_DEBUG: (cbfa3ed77c7b09e2): Tearing down pending resources...
root: INFO: Job 2017-07-07_10_36_58-10630794781884904388 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.91323662075 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 9.33153419095 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 15.4419865068 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 34.1484348436 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 429.018s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_10_36_58-10630794781884904388?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_10_36_59-15357009055266749734?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 #2676
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2676/display/redirect?page=changes>
Changes:
[klk] Update Dataflow container version to 20170706
------------------------------------------
[...truncated 586.81 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_1499445699733",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T16:41:40.942674Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_09_41_40-1660184463916081047'
location: u'global'
name: u'beamapp-jenkins-0707164139-769543'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_09_41_40-1660184463916081047]
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_09_41_40-1660184463916081047
root: INFO: Job 2017-07-07_09_41_40-1660184463916081047 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T16:41:40.427Z: JOB_MESSAGE_WARNING: (170a28f9515712fa): 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-07T16:41:42.725Z: JOB_MESSAGE_DETAILED: (c066ed4407a312cd): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T16:41:43.545Z: JOB_MESSAGE_DETAILED: (c066ed4407a31bac): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T16:41:43.549Z: JOB_MESSAGE_DETAILED: (c066ed4407a316e2): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T16:41:43.557Z: JOB_MESSAGE_DEBUG: (c066ed4407a31d4e): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T16:41:43.677Z: JOB_MESSAGE_DETAILED: (c066ed4407a31955): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T16:41:43.680Z: JOB_MESSAGE_DETAILED: (c066ed4407a3148b): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T16:41:43.683Z: JOB_MESSAGE_DETAILED: (c066ed4407a31fc1): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T16:41:43.688Z: JOB_MESSAGE_DETAILED: (c066ed4407a31af7): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T16:41:43.693Z: JOB_MESSAGE_DETAILED: (c066ed4407a3162d): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T16:41:43.699Z: JOB_MESSAGE_DETAILED: (c066ed4407a31163): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T16:41:43.705Z: JOB_MESSAGE_DETAILED: (c066ed4407a31c99): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T16:41:43.715Z: JOB_MESSAGE_DETAILED: (c066ed4407a317cf): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T16:41:43.720Z: JOB_MESSAGE_DETAILED: (c066ed4407a31305): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T16:41:43.831Z: JOB_MESSAGE_DEBUG: (c066ed4407a314c3): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T16:41:43.836Z: JOB_MESSAGE_DETAILED: (c066ed4407a31ff9): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T16:41:43.841Z: JOB_MESSAGE_DEBUG: (c066ed4407a31b2f): Adding workflow start and stop steps.
root: INFO: 2017-07-07T16:41:43.845Z: JOB_MESSAGE_DEBUG: (c066ed4407a31665): Assigning stage ids.
root: INFO: 2017-07-07T16:41:43.932Z: JOB_MESSAGE_DEBUG: (9aeb9dae72d4cfb4): Executing wait step start22
root: INFO: 2017-07-07T16:41:43.960Z: JOB_MESSAGE_BASIC: (a9c802fc638f641b): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T16:41:44.166Z: JOB_MESSAGE_DEBUG: (9c1fee14b2c739e): Starting worker pool setup.
root: INFO: 2017-07-07T16:41:44.169Z: JOB_MESSAGE_BASIC: (9c1fee14b2c7778): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T16:41:44.222Z: JOB_MESSAGE_DEBUG: (a9c802fc638f684d): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T16:41:44.245Z: JOB_MESSAGE_BASIC: (9aeb9dae72d4cb43): 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-07T16:41:45.446Z: JOB_MESSAGE_BASIC: (9fa88e6ccd4f40ca): BigQuery export job "dataflow_job_11504601846070070264" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_11504601846070070264".
root: INFO: 2017-07-07T16:42:16.249Z: JOB_MESSAGE_DETAILED: (52c614ad2185d961): BigQuery export job progress: "dataflow_job_11504601846070070264" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T16:42:16.252Z: JOB_MESSAGE_BASIC: (52c614ad2185db23): BigQuery export job finished: "dataflow_job_11504601846070070264"
root: INFO: 2017-07-07T16:42:54.055Z: JOB_MESSAGE_DETAILED: (3defc1ed92936fd1): Workers have started successfully.
root: INFO: 2017-07-07T16:45:42.811Z: JOB_MESSAGE_BASIC: (4ce5bfbd9c796fa6): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T16:45:42.842Z: JOB_MESSAGE_BASIC: (4ce5bfbd9c796e3b): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T16:45:55.458Z: JOB_MESSAGE_BASIC: (9aeb9dae72d4c86d): Executing BigQuery import job "dataflow_job_1396877114895181870". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_1396877114895181870".
root: INFO: 2017-07-07T16:46:06.512Z: JOB_MESSAGE_BASIC: (9aeb9dae72d4c97f): BigQuery import job "dataflow_job_1396877114895181870" done.
root: INFO: 2017-07-07T16:46:07.600Z: JOB_MESSAGE_DEBUG: (9aeb9dae72d4c597): Executing success step success20
root: INFO: 2017-07-07T16:46:07.713Z: JOB_MESSAGE_DETAILED: (c066ed4407a31e73): Cleaning up.
root: INFO: 2017-07-07T16:46:07.716Z: JOB_MESSAGE_DEBUG: (c066ed4407a319a9): Starting worker pool teardown.
root: INFO: 2017-07-07T16:46:07.718Z: JOB_MESSAGE_BASIC: (c066ed4407a314df): Stopping worker pool...
root: INFO: 2017-07-07T16:47:42.734Z: JOB_MESSAGE_BASIC: (c066ed4407a315b0): Worker pool stopped.
root: INFO: 2017-07-07T16:47:42.780Z: JOB_MESSAGE_DEBUG: (c066ed4407a31752): Tearing down pending resources...
root: INFO: Job 2017-07-07_09_41_40-1660184463916081047 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.60389508064 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.1073430388 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 17.8448161328 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 38.3079206856 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 443.157s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_09_41_40-1660184463916081047?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_09_41_41-7603646037229814931?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 #2675
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2675/display/redirect>
------------------------------------------
[...truncated 584.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_1499442830373",
"user_name": "Write/WriteToBigQuery/NativeWrite",
"write_disposition": "WRITE_TRUNCATE"
}
}
],
"type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
createTime: u'2017-07-07T15:53:51.376149Z'
currentStateTime: u'1970-01-01T00:00:00Z'
id: u'2017-07-07_08_53_50-5576949949720010953'
location: u'global'
name: u'beamapp-jenkins-0707155350-405409'
projectId: u'apache-beam-testing'
stageStates: []
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-07-07_08_53_50-5576949949720010953]
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_08_53_50-5576949949720010953
root: INFO: Job 2017-07-07_08_53_50-5576949949720010953 is in state JOB_STATE_RUNNING
root: INFO: 2017-07-07T15:53:50.954Z: JOB_MESSAGE_WARNING: (4d654e6e6b31a110): 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-07T15:53:52.898Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971655): Checking required Cloud APIs are enabled.
root: INFO: 2017-07-07T15:53:53.909Z: JOB_MESSAGE_DETAILED: (24a5a3d3f79717cf): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-07-07T15:53:53.912Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971805): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-07-07T15:53:53.918Z: JOB_MESSAGE_DEBUG: (24a5a3d3f7971871): Annotating graph with Autotuner information.
root: INFO: 2017-07-07T15:53:53.999Z: JOB_MESSAGE_DETAILED: (24a5a3d3f79710f8): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-07-07T15:53:54.001Z: JOB_MESSAGE_DETAILED: (24a5a3d3f797112e): Fusing consumer months with tornadoes into read
root: INFO: 2017-07-07T15:53:54.004Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971164): Fusing consumer monthly count/GroupByKey/Reify into monthly count/GroupByKey+monthly count/Combine/Partial
root: INFO: 2017-07-07T15:53:54.007Z: JOB_MESSAGE_DETAILED: (24a5a3d3f797119a): Fusing consumer format into monthly count/Combine/Extract
root: INFO: 2017-07-07T15:53:54.009Z: JOB_MESSAGE_DETAILED: (24a5a3d3f79711d0): Fusing consumer monthly count/Combine/Extract into monthly count/Combine
root: INFO: 2017-07-07T15:53:54.012Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971206): Fusing consumer Write/WriteToBigQuery/NativeWrite into format
root: INFO: 2017-07-07T15:53:54.014Z: JOB_MESSAGE_DETAILED: (24a5a3d3f797123c): Fusing consumer monthly count/Combine into monthly count/GroupByKey/Read
root: INFO: 2017-07-07T15:53:54.016Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971272): Fusing consumer monthly count/GroupByKey+monthly count/Combine/Partial into months with tornadoes
root: INFO: 2017-07-07T15:53:54.019Z: JOB_MESSAGE_DETAILED: (24a5a3d3f79712a8): Fusing consumer monthly count/GroupByKey/Write into monthly count/GroupByKey/Reify
root: INFO: 2017-07-07T15:53:54.050Z: JOB_MESSAGE_DEBUG: (24a5a3d3f7971566): Workflow config is missing a default resource spec.
root: INFO: 2017-07-07T15:53:54.053Z: JOB_MESSAGE_DETAILED: (24a5a3d3f797159c): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-07-07T15:53:54.055Z: JOB_MESSAGE_DEBUG: (24a5a3d3f79715d2): Adding workflow start and stop steps.
root: INFO: 2017-07-07T15:53:54.058Z: JOB_MESSAGE_DEBUG: (24a5a3d3f7971608): Assigning stage ids.
root: INFO: 2017-07-07T15:53:54.126Z: JOB_MESSAGE_DEBUG: (e61e0e101812c9bb): Executing wait step start22
root: INFO: 2017-07-07T15:53:54.141Z: JOB_MESSAGE_BASIC: (b4b4eecbf14cd532): Executing operation monthly count/GroupByKey/Create
root: INFO: 2017-07-07T15:53:54.345Z: JOB_MESSAGE_DEBUG: (5a54ee7b7884ea88): Starting worker pool setup.
root: INFO: 2017-07-07T15:53:54.347Z: JOB_MESSAGE_BASIC: (5a54ee7b7884eb06): Starting 1 workers in us-central1-f...
root: INFO: 2017-07-07T15:53:54.375Z: JOB_MESSAGE_DEBUG: (e61e0e101812cd06): Value "monthly count/GroupByKey/Session" materialized.
root: INFO: 2017-07-07T15:53:54.405Z: JOB_MESSAGE_BASIC: (b4b4eecbf14cd017): 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-07T15:53:55.441Z: JOB_MESSAGE_BASIC: (40591d1c2710f53d): BigQuery export job "dataflow_job_4636769298106350719" started. You can check its status with the bq tool: "bq show -j --project_id=clouddataflow-readonly dataflow_job_4636769298106350719".
root: INFO: 2017-07-07T15:54:25.979Z: JOB_MESSAGE_DETAILED: (2f57f5a52ac56a98): BigQuery export job progress: "dataflow_job_4636769298106350719" observed total of 1 exported files thus far.
root: INFO: 2017-07-07T15:54:25.982Z: JOB_MESSAGE_BASIC: (2f57f5a52ac568d6): BigQuery export job finished: "dataflow_job_4636769298106350719"
root: INFO: 2017-07-07T15:54:43.172Z: JOB_MESSAGE_DETAILED: (7fd0fc7ee76c459): Workers have started successfully.
root: INFO: 2017-07-07T15:57:41.247Z: JOB_MESSAGE_BASIC: (f22aeb8f1b1b7a95): Executing operation monthly count/GroupByKey/Close
root: INFO: 2017-07-07T15:57:41.273Z: JOB_MESSAGE_BASIC: (b4b4eecbf14cd3f3): Executing operation monthly count/GroupByKey/Read+monthly count/Combine+monthly count/Combine/Extract+format+Write/WriteToBigQuery/NativeWrite
root: INFO: 2017-07-07T15:57:55.042Z: JOB_MESSAGE_BASIC: (f22aeb8f1b1b7aa8): Executing BigQuery import job "dataflow_job_14529363282636093581". You can check its status with the bq tool: "bq show -j --project_id=apache-beam-testing dataflow_job_14529363282636093581".
root: INFO: 2017-07-07T15:58:05.852Z: JOB_MESSAGE_BASIC: (f22aeb8f1b1b7626): BigQuery import job "dataflow_job_14529363282636093581" done.
root: INFO: 2017-07-07T15:58:07.268Z: JOB_MESSAGE_DEBUG: (f22aeb8f1b1b7ace): Executing success step success20
root: INFO: 2017-07-07T15:58:07.342Z: JOB_MESSAGE_DETAILED: (24a5a3d3f7971716): Cleaning up.
root: INFO: 2017-07-07T15:58:07.346Z: JOB_MESSAGE_DEBUG: (24a5a3d3f797174c): Starting worker pool teardown.
root: INFO: 2017-07-07T15:58:07.349Z: JOB_MESSAGE_BASIC: (24a5a3d3f7971782): Stopping worker pool...
root: INFO: 2017-07-07T15:59:37.357Z: JOB_MESSAGE_BASIC: (24a5a3d3f7971fd3): Worker pool stopped.
root: INFO: 2017-07-07T15:59:37.462Z: JOB_MESSAGE_DEBUG: (24a5a3d3f7971890): Tearing down pending resources...
root: INFO: Job 2017-07-07_08_53_50-5576949949720010953 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.08774902396 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 5.57329878263 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.2664820848 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 26.9780609978 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 416.144s
FAILED (errors=1)
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_08_53_50-5576949949720010953?project=apache-beam-testing
Found: https://console.cloud.google.com/dataflow/job/2017-07-07_08_53_51-18256370938363703844?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user klk@google.com