See 
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/4502/display/redirect?page=changes>

Changes:

[noreply] Add Java IO Direct jobs: MongoDb, Mqtt, Parquet, RabbitMq, SingleStore


------------------------------------------
[...truncated 1.59 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Expanding 'SqlTransform(beam:external:java:sql:v1)' with URN 
'beam:external:java:sql:v1'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
Dependencies list: {}
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:53:45 PM 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
 payloadToConfig
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Configuration class 
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
 has no schema registered. Attempting to construct with setter approach.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:53:45 PM 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
 payloadToConfig
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Configuration class 
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
 has no schema registered. Attempting to construct with setter approach.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:53:47 PM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner 
convertToBeamRel
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: SQL:
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 SELECT 
COUNT(*) AS `count`
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 FROM 
`beam`.`PCOLLECTION` AS `PCOLLECTION`
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:53:47 PM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner 
convertToBeamRel
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
SQLPlan>
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
LogicalAggregate(group=[{}], count=[COUNT()])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
BeamIOSourceRel(table=[[beam, PCOLLECTION]])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:53:47 PM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner 
convertToBeamRel
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
BEAMPlan>
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
BeamAggregationRel(group=[{}], count=[COUNT()])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
BeamIOSourceRel(table=[[beam, PCOLLECTION]])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     root:environments.py:317 No image given, using default Python SDK image
INFO     root:environments.py:320 Python SDK container image set to 
"apache/beam_python3.8_sdk:2.51.0.dev" for Docker environment
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function pack_combiners at 0x7ff6b96bfa60> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function lift_combiners at 0x7ff6b96bfaf0> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function sort_stages at 0x7ff6b96c0280> 
====================
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to STOPPED
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to STARTING
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to RUNNING
INFO     root:portable_runner.py:569 ==================== <function 
annotate_downstream_side_inputs at 0x7fbf0e3eb5e0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
fix_side_input_pcoll_coders at 0x7fbf0e3eb700> ====================
INFO     root:portable_runner.py:569 ==================== <function 
pack_combiners at 0x7fbf0e3ebc10> ====================
INFO     root:portable_runner.py:569 ==================== <function 
lift_combiners at 0x7fbf0e3ebca0> ====================
INFO     root:portable_runner.py:569 ==================== <function expand_sdf 
at 0x7fbf0e3ebe50> ====================
INFO     root:portable_runner.py:569 ==================== <function expand_gbk 
at 0x7fbf0e3ebee0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
sink_flattens at 0x7fbf0e3e8040> ====================
INFO     root:portable_runner.py:569 ==================== <function 
greedily_fuse at 0x7fbf0e3e80d0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
read_to_impulse at 0x7fbf0e3e8160> ====================
INFO     root:portable_runner.py:569 ==================== <function 
impulse_to_input at 0x7fbf0e3e81f0> ====================
INFO     root:portable_runner.py:569 ==================== <function sort_stages 
at 0x7fbf0e3e8430> ====================
INFO     root:portable_runner.py:569 ==================== <function 
add_impulse_to_dangling_transforms at 0x7fbf0e3e8550> ====================
INFO     root:portable_runner.py:569 ==================== <function 
setup_timer_mapping at 0x7fbf0e3e83a0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
populate_data_channel_coders at 0x7fbf0e3e84c0> ====================
INFO     root:portable_runner.py:569 starting control server on port 43865
INFO     root:portable_runner.py:569 starting data server on port 35081
INFO     root:portable_runner.py:569 starting state server on port 45957
INFO     root:portable_runner.py:569 starting logging server on port 40417
INFO     root:portable_runner.py:569 Created Worker handler 
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
 object at 0x7fbf0c23d5e0> for environment 
ref_Environment_default_environment_2 (beam:env:docker:v1, 
b'\n$apache/beam_python3.8_sdk:2.51.0.dev')
INFO     root:portable_runner.py:569 Attempting to pull image 
apache/beam_python3.8_sdk:2.51.0.dev
INFO     root:portable_runner.py:569 Unable to pull image 
apache/beam_python3.8_sdk:2.51.0.dev, defaulting to local image if it exists
INFO     root:portable_runner.py:569 Waiting for docker to start up. Current 
status is running
INFO     root:portable_runner.py:569 Docker container is running. container_id 
= b'867747fee6f1655ae8fe6f8aefd4bdda9749c11c06dbdee9ed97bd190724d94f', 
worker_id = worker_85
INFO     root:portable_runner.py:569 Created Worker handler 
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
 object at 0x7fbf42c944f0> for environment external_8beam:env:docker:v1 
(beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.51.0.dev')
INFO     root:portable_runner.py:569 Attempting to pull image 
apache/beam_java8_sdk:2.51.0.dev
INFO     root:portable_runner.py:569 Unable to pull image 
apache/beam_java8_sdk:2.51.0.dev, defaulting to local image if it exists
INFO     root:portable_runner.py:569 Waiting for docker to start up. Current 
status is running
INFO     root:portable_runner.py:569 Docker container is running. container_id 
= b'c85b566678969c2d9b708466320cd97cf8ed295f59ece06332c520af1f2b237e', 
worker_id = worker_86
INFO     root:portable_runner.py:569 Completed job in 17.303510665893555 
seconds with state DONE.
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to DONE
PASSED                                                                   [ 88%]
apache_beam/transforms/sql_test.py::SqlTransformTest::test_zetasql_generate_data
 
-------------------------------- live log call ---------------------------------
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:239 Using 
pre-built snapshot at 
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.51.0-SNAPSHOT.jar>
INFO     root:external.py:929 Starting a JAR-based expansion service from JAR 
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.51.0-SNAPSHOT.jar>
 
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:116 Starting 
service with ['java' '-jar' 
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.51.0-SNAPSHOT.jar'>
 '49221' 
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.51.0-SNAPSHOT.jar']>
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Starting 
expansion service at localhost:49221
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:14 PM org.apache.beam.sdk.expansion.service.ExpansionService 
loadRegisteredTransforms
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Registering external transforms: [beam:external:java:sql:v1, 
beam:transform:org.apache.beam:pubsub_read:v1, 
beam:transform:org.apache.beam:pubsub_write:v1, 
beam:transform:org.apache.beam:pubsublite_write:v1, 
beam:transform:org.apache.beam:pubsublite_read:v1, 
beam:transform:org.apache.beam:spanner_insert:v1, 
beam:transform:org.apache.beam:spanner_update:v1, 
beam:transform:org.apache.beam:spanner_replace:v1, 
beam:transform:org.apache.beam:spanner_insert_or_update:v1, 
beam:transform:org.apache.beam:spanner_delete:v1, 
beam:transform:org.apache.beam:spanner_read:v1, 
beam:transform:org.apache.beam:kafka_read_with_metadata:v1, 
beam:transform:org.apache.beam:kafka_read_without_metadata:v1, 
beam:transform:org.apache.beam:kafka_write:v1, 
beam:external:java:generate_sequence:v1]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
Registered transforms:
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:external:java:sql:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@3c46e67a
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:pubsub_read:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@c730b35
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:pubsub_write:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@206a70ef
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:pubsublite_write:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@292b08d6
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:pubsublite_read:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@22555ebf
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_insert:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@36ebc363
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_update:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@45752059
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_replace:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@34e9fd99
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_insert_or_update:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@3c41ed1d
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_delete:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@54d9d12d
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:spanner_read:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@38425407
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:kafka_read_with_metadata:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@43bc63a3
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:kafka_read_without_metadata:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@702657cc
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:transform:org.apache.beam:kafka_write:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@6a6cb05c
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:external:java:generate_sequence:v1: 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@40a4337a
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
Registered SchemaTransformProviders:
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:spanner_cdc_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigtable_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:spanner_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:pubsublite_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigquery_storage_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigquery_fileloads_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigquery_export_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:kafka_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:kafka_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigquery_storage_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
schematransform:org.apache.beam:sql_transform:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:pubsub_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:pubsub_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:bigtable_read:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
beam:schematransform:org.apache.beam:pubsublite_write:v1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:15 PM org.apache.beam.sdk.expansion.service.ExpansionService expand
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Expanding 'SqlTransform(beam:external:java:sql:v1)' with URN 
'beam:external:java:sql:v1'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
Dependencies list: {}
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:15 PM 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
 payloadToConfig
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Configuration class 
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
 has no schema registered. Attempting to construct with setter approach.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:16 PM 
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
 payloadToConfig
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Configuration class 
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
 has no schema registered. Attempting to construct with setter approach.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:18 PM com.google.zetasql.io.grpc.NameResolverRegistry 
getDefaultRegistry
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
No NameResolverProviders found via ServiceLoader, including for DNS. This is 
probably due to a broken build. If using ProGuard, check your configuration
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Aug 21, 
2023 5:54:20 PM org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner 
convertToBeamRelInternal
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
BEAMPlan>
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
BeamZetaSqlCalcRel(expr#0=[{inputs}], expr#1=[1:BIGINT], 
expr#2=['foo':VARCHAR], expr#3=[3.1400000000000001243E0:DOUBLE], int=[$t1], 
str=[$t2], flt=[$t3])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   
BeamValuesRel(tuples=[[{ 0 }]])
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     root:environments.py:317 No image given, using default Python SDK image
INFO     root:environments.py:320 Python SDK container image set to 
"apache/beam_python3.8_sdk:2.51.0.dev" for Docker environment
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function pack_combiners at 0x7ff6b96bfa60> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function lift_combiners at 0x7ff6b96bfaf0> 
====================
INFO     
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710 
==================== <function sort_stages at 0x7ff6b96c0280> 
====================
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to STOPPED
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to STARTING
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to RUNNING
INFO     root:portable_runner.py:569 ==================== <function 
annotate_downstream_side_inputs at 0x7fbf0e3eb5e0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
fix_side_input_pcoll_coders at 0x7fbf0e3eb700> ====================
INFO     root:portable_runner.py:569 ==================== <function 
pack_combiners at 0x7fbf0e3ebc10> ====================
INFO     root:portable_runner.py:569 ==================== <function 
lift_combiners at 0x7fbf0e3ebca0> ====================
INFO     root:portable_runner.py:569 ==================== <function expand_sdf 
at 0x7fbf0e3ebe50> ====================
INFO     root:portable_runner.py:569 ==================== <function expand_gbk 
at 0x7fbf0e3ebee0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
sink_flattens at 0x7fbf0e3e8040> ====================
INFO     root:portable_runner.py:569 ==================== <function 
greedily_fuse at 0x7fbf0e3e80d0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
read_to_impulse at 0x7fbf0e3e8160> ====================
INFO     root:portable_runner.py:569 ==================== <function 
impulse_to_input at 0x7fbf0e3e81f0> ====================
INFO     root:portable_runner.py:569 ==================== <function sort_stages 
at 0x7fbf0e3e8430> ====================
INFO     root:portable_runner.py:569 ==================== <function 
add_impulse_to_dangling_transforms at 0x7fbf0e3e8550> ====================
INFO     root:portable_runner.py:569 ==================== <function 
setup_timer_mapping at 0x7fbf0e3e83a0> ====================
INFO     root:portable_runner.py:569 ==================== <function 
populate_data_channel_coders at 0x7fbf0e3e84c0> ====================
INFO     root:portable_runner.py:569 starting control server on port 33079
INFO     root:portable_runner.py:569 starting data server on port 39111
INFO     root:portable_runner.py:569 starting state server on port 37113
INFO     root:portable_runner.py:569 starting logging server on port 42885
INFO     root:portable_runner.py:569 Created Worker handler 
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
 object at 0x7fbf42cfc4f0> for environment external_9beam:env:docker:v1 
(beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.51.0.dev')
INFO     root:portable_runner.py:569 Attempting to pull image 
apache/beam_java8_sdk:2.51.0.dev
INFO     root:portable_runner.py:569 Unable to pull image 
apache/beam_java8_sdk:2.51.0.dev, defaulting to local image if it exists
INFO     root:portable_runner.py:569 Waiting for docker to start up. Current 
status is running
INFO     root:portable_runner.py:569 Docker container is running. container_id 
= b'2d7d6d29d4d073b9bd6a2cd3fb24fbdcaae6b3a9c4d5ca4a1abea3ae5a438cd8', 
worker_id = worker_87
INFO     root:portable_runner.py:569 Created Worker handler 
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
 object at 0x7fbf42cd8a90> for environment 
ref_Environment_default_environment_2 (beam:env:docker:v1, 
b'\n$apache/beam_python3.8_sdk:2.51.0.dev')
INFO     root:portable_runner.py:569 Attempting to pull image 
apache/beam_python3.8_sdk:2.51.0.dev
INFO     root:portable_runner.py:569 Unable to pull image 
apache/beam_python3.8_sdk:2.51.0.dev, defaulting to local image if it exists
INFO     root:portable_runner.py:569 Waiting for docker to start up. Current 
status is running
INFO     root:portable_runner.py:569 Docker container is running. container_id 
= b'042c7509b67493bf2ff4b9fd159ebdb930e0d354df3d18ccc25205633b05c374', 
worker_id = worker_88
INFO     root:portable_runner.py:569 Completed job in 18.013468503952026 
seconds with state DONE.
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:576 
Job state changed to DONE
PASSED                                                                   [100%]

=============================== warnings summary ===============================
../../build/gradleenv/1922375555/lib/python3.8/site-packages/hdfs/config.py:28
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/hdfs/config.py>:28:
 DeprecationWarning: the imp module is deprecated in favour of importlib; see 
the module's documentation for alternative uses
    from imp import load_source

../../build/gradleenv/1922375555/lib/python3.8/site-packages/google/rpc/__init__.py:18
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/google/rpc/__init__.py>:18:
 DeprecationWarning: pkg_resources is deprecated as an API. See 
https://setuptools.pypa.io/en/latest/pkg_resources.html
    import pkg_resources

../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2871:
 20 warnings
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py>:2871:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    declare_namespace(pkg)

../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2871:
 16 warnings
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py>:2871:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google.cloud')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    declare_namespace(pkg)

../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2350
../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2350
../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2350
../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2350
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py>:2350:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    declare_namespace(parent)

../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2871
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py>:2871:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google.logging')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    declare_namespace(pkg)

../../build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py:2871
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/pkg_resources/__init__.py>:2871:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google.iam')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    declare_namespace(pkg)

../../build/gradleenv/1922375555/lib/python3.8/site-packages/google/rpc/__init__.py:20
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/google/rpc/__init__.py>:20:
 DeprecationWarning: Deprecated call to 
`pkg_resources.declare_namespace('google.rpc')`.
  Implementing implicit namespace packages (as specified in PEP 420) is 
preferred to `pkg_resources.declare_namespace`. See 
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
    pkg_resources.declare_namespace(__name__)

apache_beam/transforms/sql_test.py::SqlTransformTest::test_agg
apache_beam/transforms/sql_test.py::SqlTransformTest::test_filter
apache_beam/transforms/sql_test.py::SqlTransformTest::test_generate_data
apache_beam/transforms/sql_test.py::SqlTransformTest::test_map
apache_beam/transforms/sql_test.py::SqlTransformTest::test_project
apache_beam/transforms/sql_test.py::SqlTransformTest::test_row
apache_beam/transforms/sql_test.py::SqlTransformTest::test_tagged_join
apache_beam/transforms/sql_test.py::SqlTransformTest::test_windowing_before_sql
apache_beam/transforms/sql_test.py::SqlTransformTest::test_zetasql_generate_data
  
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/transforms/external.py>:676:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    self._expansion_service, pipeline.options)

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/pytest_xlangSqlValidateRunner.xml>
 -
=== 9 passed, 15 skipped, 6957 deselected, 54 warnings in 334.81s (0:05:34) ====

> Task :sdks:python:test-suites:direct:xlang:fnApiJobServerCleanup
Killing process at 4038628

> Task :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerCleanup
Stopping expansion service pid: 4042623.
Stopping expansion service pid: 4042624.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingJava'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.6.2/userguide/command_line_interface.html#sec:command_line_warnings

Execution optimizations have been disabled for 1 invalid unit(s) of work during 
this build to ensure correctness.
Please consult deprecation warnings for more details.

BUILD FAILED in 44m 26s
258 actionable tasks: 167 executed, 79 from cache, 12 up-to-date

Publishing build scan...
https://ge.apache.org/s/nmq7gty6cyow2

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

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

Reply via email to