See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/4156/display/redirect>

Changes:


------------------------------------------
[...truncated 12.07 MB...]
INFO:apache_beam.utils.subprocess_server:Starting service with ['java' '-jar' 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/runners/spark/3/job-server/build/libs/beam-runners-spark-3-job-server-2.49.0-SNAPSHOT.jar'>
 '--spark-master-url' 'local[4]' '--artifacts-dir' 
'/tmp/beam-tempd4otlvgv/artifactsktn5au82' '--job-port' '53823' 
'--artifact-port' '0' '--expansion-port' '0']
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:22 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:22 INFO 
org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingService 
started on localhost:32875
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:22 INFO 
org.apache.beam.runners.jobsubmission.JobServerDriver: Java ExpansionService 
started on localhost:35021
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:22 INFO 
org.apache.beam.runners.jobsubmission.JobServerDriver: JobService started on 
localhost:53823
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:22 INFO 
org.apache.beam.runners.jobsubmission.JobServerDriver: Job server now running, 
terminate with Ctrl+C
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Staging 
artifacts for job_b92b1b38-e393-48eb-b07b-f5d79219abc2.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Resolving 
artifacts for 
job_b92b1b38-e393-48eb-b07b-f5d79219abc2.ref_Environment_default_environment_1.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Getting 1 
artifacts for job_b92b1b38-e393-48eb-b07b-f5d79219abc2.null.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Artifacts 
fully staged for job_b92b1b38-e393-48eb-b07b-f5d79219abc2.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.spark.SparkJobInvoker: Invoking job 
BeamApp-jenkins-0529143123-af8e5c8b_af18dbe0-98c8-43d0-8630-f7cec0872d12
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.jobsubmission.JobInvocation: Starting job invocation 
BeamApp-jenkins-0529143123-af8e5c8b_af18dbe0-98c8-43d0-8630-f7cec0872d12
INFO:apache_beam.runners.portability.portable_runner:Environment "LOOPBACK" has 
started a component necessary for the execution. Be sure to run the pipeline 
using
  with Pipeline() as p:
    p.apply(..)
This ensures that the pipeline finishes before this program exits.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
RUNNING
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:23 INFO 
org.apache.beam.runners.spark.translation.SparkContextFactory: Creating a brand 
new Spark Context.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:24 WARN 
org.apache.hadoop.util.NativeCodeLoader: Unable to load native-hadoop library 
for your platform... using builtin-java classes where applicable
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:24 INFO 
org.sparkproject.jetty.util.log: Logging initialized @4847ms to 
org.sparkproject.jetty.util.log.Slf4jLog
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.Server: jetty-9.4.40.v20210413; built: 
2021-04-13T20:42:42.668Z; git: b881a572662e1943a14ae12e7e1207989f218b74; jvm 
1.8.0_362-8u372-ga~us1-0ubuntu1~20.04-b09
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.Server: Started @5083ms
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.AbstractConnector: Started 
ServerConnector@4ed3ebe5{HTTP/1.1, (http/1.1)}{127.0.0.1:4040}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@604a8395{/jobs,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@33ee52d3{/jobs/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@25604f17{/jobs/job,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@1796577a{/jobs/job/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@51085d93{/stages,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@1917513a{/stages/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@77e7ff5e{/stages/stage,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@3d57519f{/stages/stage/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@76e8a362{/stages/pool,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@16ba8966{/stages/pool/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@6e108327{/storage,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@aa87b4c{/storage/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@3b82684d{/storage/rdd,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@6367e68b{/storage/rdd/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@14b6f374{/environment,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@67f3d3c{/environment/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@68c705ab{/executors,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@4b589c70{/executors/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@1bbcaf22{/executors/threadDump,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@2e8b4fe0{/executors/threadDump/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@2bc08096{/static,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@5756f30f{/,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@2a9110d4{/api,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@781c9595{/jobs/job/kill,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@a7dbe47{/stages/stage/kill,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.sparkproject.jetty.server.handler.ContextHandler: Started 
o.s.j.s.ServletContextHandler@52be3b2d{/metrics/json,null,AVAILABLE,@Spark}
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.apache.beam.runners.spark.metrics.MetricsAccumulator: Instantiated metrics 
accumulator: MetricQueryResults()
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:25 INFO 
org.apache.beam.runners.spark.SparkPipelineRunner: Running job 
BeamApp-jenkins-0529143123-af8e5c8b_af18dbe0-98c8-43d0-8630-f7cec0872d12 on 
Spark master local[4]
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:26 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:26 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:26 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:26 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.runners.worker.statecache:Creating state cache with size 0
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure control channel 
for localhost:39071.
INFO:apache_beam.runners.worker.sdk_worker:Control channel established.
INFO:apache_beam.runners.worker.sdk_worker:Initializing SDKHarness with 
unbounded number of workers.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam 
Fn Control client connected with id 1-1
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-2
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure state channel for 
localhost:35703.
INFO:apache_beam.runners.worker.sdk_worker:State channel established.
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.runners.worker.data_plane:Creating client data channel for 
localhost:40693
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client 
connected.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-3
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-4
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-5
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-8
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-6
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-7
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:27 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-9
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-10
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-11
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-12
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-13
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-14
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-15
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.spark.SparkPipelineRunner: Job 
BeamApp-jenkins-0529143123-af8e5c8b_af18dbe0-98c8-43d0-8630-f7cec0872d12: 
Pipeline translated successfully. Computing outputs
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 WARN 
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils: Unable to 
retrieve the requested metadata.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: 
getProcessBundleDescriptor request with id 1-16
INFO:root:Default Python SDK image for environment is 
apache/beam_python3.8_sdk:2.49.0.dev
INFO:apache_beam.io.filebasedsink:Starting finalize_write threads with 
num_shards: 4 (skipped: 0), batches: 4, num_threads: 4
INFO:apache_beam.io.filebasedsink:Renamed 4 shards in 0.01 seconds.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.apache.beam.runners.spark.SparkPipelineRunner: Job 
BeamApp-jenkins-0529143123-af8e5c8b_af18dbe0-98c8-43d0-8630-f7cec0872d12 
finished.
INFO:apache_beam.utils.subprocess_server:23/05/29 14:31:28 INFO 
org.sparkproject.jetty.server.AbstractConnector: Stopped 
Spark@4ed3ebe5{HTTP/1.1, (http/1.1)}{127.0.0.1:4040}
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
Exception in thread read_state:
Traceback (most recent call last):
  File "/usr/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.8/threading.py", line 870, in run
Exception in thread run_worker_1-1:
Traceback (most recent call last):
  File "/usr/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 1039, in pull_responses
    self._target(*self._args, **self._kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 262, in run
    for work_request in self._control_stub.Control(get_responses()):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 475, in __next__
    for response in responses:
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 475, in __next__
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 881, in _next
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 881, in _next
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.UNAVAILABLE
        details = "Socket closed"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:39071 {created_time:"2023-05-29T14:31:29.049345531+00:00", 
grpc_status:14, grpc_message:"Socket closed"}"
>
ERROR:apache_beam.runners.worker.data_plane:Failed to read inputs in the data 
plane.
Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 652, in _read_inputs
    for elements in elements_iterator:
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 475, in __next__
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 881, in _next
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.UNAVAILABLE
        details = "recvmsg:Connection reset by peer"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:40693 {grpc_message:"recvmsg:Connection reset by peer", 
grpc_status:14, created_time:"2023-05-29T14:31:29.04930946+00:00"}"
>
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
  File "/usr/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.UNAVAILABLE
        details = "recvmsg:Connection reset by peer"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:35703 {created_time:"2023-05-29T14:31:29.049293922+00:00", 
grpc_status:14, grpc_message:"recvmsg:Connection reset by peer"}"
>
    self.run()
  File "/usr/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 669, in <lambda>
    target=lambda: self._read_inputs(elements_iterator),
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 652, in _read_inputs
    for elements in elements_iterator:
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 475, in __next__
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/build/gradleenv/2022703442/lib/python3.8/site-packages/grpc/_channel.py";,>
 line 881, in _next
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.UNAVAILABLE
        details = "recvmsg:Connection reset by peer"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:40693 {grpc_message:"recvmsg:Connection reset by peer", 
grpc_status:14, created_time:"2023-05-29T14:31:29.04930946+00:00"}"
>

> Task :sdks:python:test-suites:portable:py38:postCommitPy38

> Task :sdks:python:test-suites:dataflow:py38:postCommitIT
warning: sdist: standard file not found: should have one of README, README.rst, 
README.txt, README.md

warning: check: missing required meta-data: url

warning: check: missing meta-data: either (author and author_email) or 
(maintainer and maintainer_email) must be supplied


> Task :sdks:python:test-suites:dataflow:py38:postCommitIT FAILED

FAILURE: Build failed with an exception.

* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
 line: 141

* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py38:postCommitIT'.
> 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.5.1/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 2h 8m 1s
214 actionable tasks: 149 executed, 59 from cache, 6 up-to-date

Publishing build scan...

Publishing failed.

The response from https://ge.apache.org/scans/publish/gradle/3.13.2/token was 
not from Gradle Enterprise.
The specified server address may be incorrect, or your network environment may 
be interfering.

Please report this problem to your Gradle Enterprise administrator via 
https://ge.apache.org/help and include the following via copy/paste:

----------
Gradle version: 7.5.1
Plugin version: 3.13.2
Request URL: https://ge.apache.org/scans/publish/gradle/3.13.2/token
Request ID: ad41b7da-2644-45dd-96b2-dd9be6c5683d
Response status code: 502
Response content type: text/html
----------

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