See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/5091/display/redirect>
Changes: ------------------------------------------ [...truncated 1.73 MB...] E AttributeError: 'bytes' object has no attribute 'end' apache_beam/runners/portability/portable_runner.py:576: RuntimeError ------------------------------ Captured log call ------------------------------- INFO apache_beam.utils.subprocess_server:subprocess_server.py:339 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.54.0-SNAPSHOT.jar> INFO root:external.py:1017 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.54.0-SNAPSHOT.jar> INFO apache_beam.utils.subprocess_server:subprocess_server.py:203 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.54.0-SNAPSHOT.jar'> '45883' '--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.54.0-SNAPSHOT.jar'> '--alsoStartLoopbackWorker'] INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Starting expansion service at localhost:45883 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:36 AM org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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, beam:transform:org.apache.beam:bigquery_read:v1, beam:transform:org.apache.beam:bigquery_write:v1, beam:transform:pubsub_read:v1, beam:transform:pubsub_write:v1, beam:transform:pubsub_write:v2, beam:transform:combine_globally:v1, beam:transform:combine_grouped_values:v1, beam:transform:combine_per_key:v1, beam:transform:create_view:v1, beam:transform:flatten:v1, beam:transform:group_by_key:v1, beam:transform:group_into_batches:v1, beam:transform:group_into_batches_with_sharded_key:v1, beam:transform:impulse:v1, beam:transform:reshuffle:v1, beam:transform:sdf_process_keyed_elements:v1, beam:transform:teststream:v1, beam:transform:window_into:v1, beam:transform:write_files:v1] INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Registered transforms: INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:external:java:sql:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@6c779568 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:pubsub_read:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@f381794 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:pubsub_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@2cdd0d4b INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:pubsublite_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@7e9131d5 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:pubsublite_read:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@2e1d27ba INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_insert:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@61d6015a INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_update:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@2525ff7e INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_replace:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@524d6d96 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_insert_or_update:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@152aa092 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_delete:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@44a7bfbc INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:spanner_read:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@4ef37659 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:kafka_read_with_metadata:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@776b83cc INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:kafka_read_without_metadata:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@37858383 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:kafka_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@4e268090 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:external:java:generate_sequence:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@1bb266b3 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:bigquery_read:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@306cf3ea INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:org.apache.beam:bigquery_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@2beee7ff INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:pubsub_read:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@5136d012 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:pubsub_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@5939a379 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:pubsub_write:v2: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@e1de817 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:combine_globally:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@52102734 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:combine_grouped_values:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@3541cb24 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:combine_per_key:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@2177849e INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:create_view:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@40cb8df7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:flatten:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@13b13b5d INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:group_by_key:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@2892dae4 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:group_into_batches:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@355ce81c INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:group_into_batches_with_sharded_key:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@29647f75 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:impulse:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@3315d2d7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:reshuffle:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@d6e7bab INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:sdf_process_keyed_elements:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@5fa07e12 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:teststream:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@55b53d44 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:window_into:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@482bce4f INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:transform:write_files:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$81/2109798150@366647c2 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Registered SchemaTransformProviders: INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:yaml:filter-java:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:spanner_cdc_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:yaml:map_to_fields-java:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigtable_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:spanner_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:pubsublite_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigquery_storage_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigquery_fileloads_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigquery_export_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:kafka_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:kafka_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigquery_storage_write:v2 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 schematransform:org.apache.beam:sql_transform:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:pubsub_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:pubsub_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:yaml:window_into_strategy:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:bigtable_read:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:pubsublite_write:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:generate_sequence:v1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 beam:schematransform:org.apache.beam:yaml:explode:v1 WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:45883. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:38 AM org.apache.beam.sdk.expansion.service.ExpansionService expand INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Expanding 'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Dependencies list: {} INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:39 AM org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader payloadToConfig INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 24, 2024 5:44:39 AM org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader payloadToConfig INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 24, 2024 5:44:41 AM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: SQL: INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 SELECT COUNT(*) AS `count` INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 FROM `beam`.`PCOLLECTION` AS `PCOLLECTION` INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:41 AM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: SQLPlan> INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 LogicalAggregate(group=[{}], count=[COUNT()]) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 BeamIOSourceRel(table=[[beam, PCOLLECTION]]) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:41 AM org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: BEAMPlan> INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 BeamAggregationRel(group=[{}], count=[COUNT()]) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 BeamIOSourceRel(table=[[beam, PCOLLECTION]]) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO root:environments.py:318 No image given, using default Python SDK image INFO root:environments.py:321 Python SDK container image set to "apache/beam_python3.8_sdk:2.54.0.dev" for Docker environment INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function pack_combiners at 0x7f0b226eaa60> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function lift_combiners at 0x7f0b226eaaf0> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function sort_stages at 0x7f0b226eb280> ==================== INFO apache_beam.runners.portability.portable_runner:portable_runner.py:550 Job state changed to STOPPED INFO apache_beam.runners.portability.portable_runner:portable_runner.py:550 Job state changed to STARTING INFO apache_beam.runners.portability.portable_runner:portable_runner.py:550 Job state changed to RUNNING INFO root:portable_runner.py:543 ==================== <function annotate_downstream_side_inputs at 0x7fefa6e831f0> ==================== INFO root:portable_runner.py:543 ==================== <function fix_side_input_pcoll_coders at 0x7fefa6e83310> ==================== INFO root:portable_runner.py:543 ==================== <function pack_combiners at 0x7fefa6e83820> ==================== INFO root:portable_runner.py:543 ==================== <function lift_combiners at 0x7fefa6e838b0> ==================== INFO root:portable_runner.py:543 ==================== <function expand_sdf at 0x7fefa6e83a60> ==================== INFO root:portable_runner.py:543 ==================== <function expand_gbk at 0x7fefa6e83af0> ==================== INFO root:portable_runner.py:543 ==================== <function sink_flattens at 0x7fefa6e83c10> ==================== INFO root:portable_runner.py:543 ==================== <function greedily_fuse at 0x7fefa6e83ca0> ==================== INFO root:portable_runner.py:543 ==================== <function read_to_impulse at 0x7fefa6e83d30> ==================== INFO root:portable_runner.py:543 ==================== <function impulse_to_input at 0x7fefa6e83dc0> ==================== INFO root:portable_runner.py:543 ==================== <function sort_stages at 0x7fefa6e84040> ==================== INFO root:portable_runner.py:543 ==================== <function add_impulse_to_dangling_transforms at 0x7fefa6e84160> ==================== INFO root:portable_runner.py:543 ==================== <function setup_timer_mapping at 0x7fefa6e83f70> ==================== INFO root:portable_runner.py:543 ==================== <function populate_data_channel_coders at 0x7fefa6e840d0> ==================== INFO root:portable_runner.py:543 starting control server on port 44343 INFO root:portable_runner.py:543 starting data server on port 41609 INFO root:portable_runner.py:543 starting state server on port 35937 INFO root:portable_runner.py:543 starting logging server on port 44751 INFO root:portable_runner.py:543 Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fefd8ec94c0> for environment ref_Environment_default_environment_2 (beam:env:docker:v1, b'\n$apache/beam_python3.8_sdk:2.54.0.dev') INFO root:portable_runner.py:543 Attempting to pull image apache/beam_python3.8_sdk:2.54.0.dev INFO root:portable_runner.py:543 Unable to pull image apache/beam_python3.8_sdk:2.54.0.dev, defaulting to local image if it exists INFO root:portable_runner.py:543 Waiting for docker to start up. Current status is running INFO root:portable_runner.py:543 Docker container is running. container_id = b'402df4a2eb45ca8e71dd5a959900e1d95b9890da53fcc86776d3d162efa48890', worker_id = worker_89 INFO root:portable_runner.py:543 Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.ExternalWorkerHandler object at 0x7fefdbe96280> for environment external_8beam:env:anyof:v1 (beam:env:external:v1, b'\n\x11\n\x0flocalhost:45883') INFO root:portable_runner.py:543 Requesting worker at localhost:45883 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:44:52 AM org.apache.beam.fn.harness.ExternalWorkerService startWorker INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Starting worker worker_90 pointing at apache-ci-beam-jenkins-13.c.apache-beam-testing.internal:44343. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:45:01 AM org.apache.beam.fn.harness.FnHarness main INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Shutting SDK harness down. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 24, 2024 5:45:01 AM org.apache.beam.fn.harness.ExternalWorkerService lambda$startWorker$0 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Successfully started worker worker_90. ERROR root:portable_runner.py:543 Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 297, in _run_job self.result = self._invoke_runner() File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 319, in _invoke_runner return fn_runner.FnApiRunner( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 224, in run_via_runner_api return self.run_stages(stage_context, stages) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 466, in run_stages bundle_results = self._execute_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 794, in _execute_bundle self._run_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1031, in _run_bundle result, splits = bundle_manager.process_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1358, in process_bundle self._send_input_to_worker(process_bundle_id, transform_id, elements) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1232, in _send_input_to_worker for byte_stream in (byte_streams or []): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 302, in __iter__ return itertools.chain(*self.partition(1)) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 288, in partition for wkvs in windowed_key_values(key, windowed_values): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1224, in process_entire_key for wvalue in self.process_elements(state, File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1376, in process_elements if input_watermark > window.end + self.allowed_lateness: AttributeError: 'bytes' object has no attribute 'end' ERROR root:portable_runner.py:543 Error running pipeline. Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 297, in _run_job self.result = self._invoke_runner() File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 319, in _invoke_runner return fn_runner.FnApiRunner( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 224, in run_via_runner_api return self.run_stages(stage_context, stages) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 466, in run_stages bundle_results = self._execute_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 794, in _execute_bundle self._run_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1031, in _run_bundle result, splits = bundle_manager.process_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1358, in process_bundle self._send_input_to_worker(process_bundle_id, transform_id, elements) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1232, in _send_input_to_worker for byte_stream in (byte_streams or []): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 302, in __iter__ return itertools.chain(*self.partition(1)) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 288, in partition for wkvs in windowed_key_values(key, windowed_values): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1224, in process_entire_key for wvalue in self.process_elements(state, File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1376, in process_elements if input_watermark > window.end + self.allowed_lateness: AttributeError: 'bytes' object has no attribute 'end' INFO apache_beam.runners.portability.portable_runner:portable_runner.py:550 Job state changed to FAILED - generated xml file: <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/pytest_xlangSqlValidateRunner.xml> - =========================== short test summary info ============================ FAILED apache_beam/transforms/sql_test.py::SqlTransformTest::test_windowing_before_sql - RuntimeError: Pipeline job-8c03aaf0-89be-47af-a0d4-e55e2c1e1e42 failed in state FAILED: Error running pipeline. Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 297, in _run_job self.result = self._invoke_runner() File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/local_job_service.py";,> line 319, in _invoke_runner return fn_runner.FnApiRunner( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 224, in run_via_runner_api return self.run_stages(stage_context, stages) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 466, in run_stages bundle_results = self._execute_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 794, in _execute_bundle self._run_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1031, in _run_bundle result, splits = bundle_manager.process_bundle( File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1358, in process_bundle self._send_input_to_worker(process_bundle_id, transform_id, elements) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1232, in _send_input_to_worker for byte_stream in (byte_streams or []): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 302, in __iter__ return itertools.chain(*self.partition(1)) File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/runners/portability/fn_api_runner/execution.py";,> line 288, in partition for wkvs in windowed_key_values(key, windowed_values): File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1224, in process_entire_key for wvalue in self.process_elements(state, File "<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/apache_beam/transforms/trigger.py";,> line 1376, in process_elements if input_watermark > window.end + self.allowed_lateness: AttributeError: 'bytes' object has no attribute 'end' ===== 1 failed, 8 passed, 17 skipped, 7304 deselected in 290.74s (0:04:50) ===== > Task > :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingSql > FAILED > Task :sdks:python:test-suites:direct:xlang:fnApiJobServerCleanup Killing process at 1555692 > Task :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerCleanup Stopping expansion service pid: 1558804. Stopping expansion service pid: 1558805. FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingSql'. > 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 9.0. You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins. For more on this, please refer to https://docs.gradle.org/8.4/userguide/command_line_interface.html#sec:command_line_warnings in the Gradle documentation. BUILD FAILED in 35m 21s 261 actionable tasks: 178 executed, 73 from cache, 10 up-to-date Publishing build scan... https://ge.apache.org/s/kxa2cnilfr3e2 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org
