See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/5184/display/redirect>

Changes:


------------------------------------------
[...truncated 2.78 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_22:0"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Unkey_39"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:element_count:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AQ==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_25"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-RestoreTags_38"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_22:0"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Unkey_39"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Match_40"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": 
"ref_AppliedPTransform_assert_that-Group-CoGroupByKeyImpl-MapTuple-collect_values-_37"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_22:0"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Match_40"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Match_40"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:element_count:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AQ==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_23"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:element_count:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AQ==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_22"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-RestoreTags_38"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Match_40"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_22:0"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:sum_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AA==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-RestoreTags_38"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:sampled_byte_size:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:distribution_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AZYBlgGWAQ==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_22"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:sampled_byte_size:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:distribution_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AX9/fw==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_23"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:sampled_byte_size:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:distribution_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AQ4ODg==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_26"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:sampled_byte_size:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:distribution_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AXt7ew==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_24"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }, 
{'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"urn": "beam:metric:sampled_byte_size:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"type": "beam:metrics:distribution_int64:v1",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"payload": "AXV1dQ==",'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      
"labels": {'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'        
"PCOLLECTION": "ref_PCollection_PCollection_25"'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'      }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'    }]'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'  }'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'}'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
FileChannelManager removed spill file directory 
/tmp/flink-io-e845861b-3c1f-4593-a6d1-ead14f377def'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment 
close'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Shutting down the network environment and its components.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
FileChannelManager removed spill file directory 
/tmp/flink-netty-shuffle-a1cf1e3a-53d4-442c-bffd-1a831b9a43c3'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Shutting down the kvState service and its components.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService 
stop'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stop job leader service.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.filecache.FileCache shutdown'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
removed file cache directory 
/tmp/flink-dist-cache-75f5148a-0f7e-4b60-932f-eaef33709f17'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
handleOnStopException'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopping Akka RPC service.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopping Akka RPC service.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$8'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopped Akka RPC service.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Shutting down BLOB cache'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Shutting down BLOB cache'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.blob.BlobServer close'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopped BLOB server at 0.0.0.0:37801'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:09 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$8'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Stopped Akka RPC service.'

apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source
 
-------------------------------- live log setup --------------------------------
INFO     apache_beam.io.gcp.bigquery_read_it_test:bigquery_read_it_test.py:104 
Created dataset python_read_table_1651584430974 in project apache-beam-testing
INFO     apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:446 Using location 
'US' from table <TableReference
                                                                  datasetId: 
'python_read_table_1651584430974'
                                                                  projectId: 
'apache-beam-testing'
                                                                  tableId: 
'python_read_table'> referenced by query SELECT * FROM 
`python_read_table_1651584430974.python_read_table`
WARNING  apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:893 Dataset 
apache-beam-testing:beam_temp_dataset_663341c9abee4faf9078893e051ba122 does not 
exist so we will create it as temporary with location=US
INFO     apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:564 Started 
BigQuery job: <JobReference
                                                                  jobId: 
'beam_bq_job_QUERY_materializing_table_before_reading_dfd48594-1_1651584431_516'
                                                                  location: 'US'
                                                                  projectId: 
'apache-beam-testing'>
                                                                  bq show -j 
--format=prettyjson --project_id=apache-beam-testing 
beam_bq_job_QUERY_materializing_table_before_reading_dfd48594-1_1651584431_516
INFO     root:bigquery_tools.py:632 Job status: RUNNING
INFO     root:bigquery_tools.py:632 Job status: DONE
-------------------------------- live log call ---------------------------------
INFO     apache_beam.runners.worker.worker_pool_main:worker_pool_main.py:93 
Listening for workers at localhost:41613
WARNING  root:environments.py:374 Make sure that locally built Python SDK 
docker image has Python 3.7 interpreter.
INFO     root:environments.py:380 Default Python SDK image for environment is 
apache/beam_python3.7_sdk:2.39.0.dev
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 
==================== <function pack_combiners at 0x7f797f3cacb0> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 
==================== <function lift_combiners at 0x7f797f3cad40> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 
==================== <function sort_stages at 0x7f797f3cb4d0> 
====================
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:116 Starting 
service with ['java' '-jar' 
'/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python37/src/runners/flink/1.14/job-server/build/libs/beam-runners-flink-1.14-job-server-2.39.0-SNAPSHOT.jar'
 '--flink-master' '[auto]' '--artifacts-dir' 
'/tmp/beam-temp34uahjm8/artifactsfzc4uc4c' '--job-port' '56343' 
'--artifact-port' '0' '--expansion-port' '0']
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:20 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils 
getItems'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 
b'WARNING: Unable to retrieve the requested metadata.'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:20 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory 
createBuilder'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: 
The AWS S3 Beam extension was included in this build, but the awsRegion flag 
was not specified. If you don't plan to use S3, then ignore this message."
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:21 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createArtifactStagingService'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
ArtifactStagingService started on localhost:36631'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:21 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createExpansionService'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Java ExpansionService started on localhost:35729'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:21 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createJobServer'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
JobService started on localhost:56343'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'May 03, 
2022 1:27:21 PM org.apache.beam.runners.jobsubmission.JobServerDriver run'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: 
Job server now running, terminate with Ctrl+C'
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-10' is disconnected.
        at 
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
        at com.sun.proxy.$Proxy132.isAlive(Unknown Source)
        at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213)
        at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205)
        at hudson.Launcher$ProcStarter.join(Launcher.java:522)
        at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806)
        at hudson.model.Build$BuildExecution.build(Build.java:198)
        at hudson.model.Build$BuildExecution.doRun(Build.java:163)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514)
        at hudson.model.Run.execute(Run.java:1888)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
        at hudson.model.ResourceController.execute(ResourceController.java:99)
        at hudson.model.Executor.run(Executor.java:432)
Caused by: hudson.remoting.Channel$OrderlyShutdown: Command Close created at
        at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1320)
        at hudson.remoting.Channel$1.handle(Channel.java:607)
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Caused by: Command Close created at
        at hudson.remoting.Command.<init>(Command.java:70)
        at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1313)
        at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1311)
        at hudson.remoting.Channel.close(Channel.java:1487)
        at hudson.remoting.Channel.close(Channel.java:1454)
        at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1319)
        ... 2 more
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-10 is offline; cannot locate jdk_1.8_latest

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to