See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/2822/display/redirect>
Changes: ------------------------------------------ [...truncated 48.62 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingExecutableStageContextFactory.java:217) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingExecutableStageContextFactory.java:193) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.release(ReferenceCountingExecutableStageContextFactory.java:182) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.scheduleRelease(ReferenceCountingExecutableStageContextFactory.java:136) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.access$300(ReferenceCountingExecutableStageContextFactory.java:48) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.close(ReferenceCountingExecutableStageContextFactory.java:213) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:269) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.close(FlinkExecutableStageFunction.java:374) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:519) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:357) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at java.lang.Thread.run(Thread.java:750) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.runners.worker.statecache:statecache.py:234 Creating state cache with size 104857600 INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:189 Creating insecure control channel for localhost:33237. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:197 Control channel established. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:247 Initializing SDKHarness with unbounded number of workers. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService control INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Beam Fn Control client connected with id 5-1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-6 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-8 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-7 INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:910 Creating insecure state channel for localhost:40937. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:917 State channel established. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-10 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.runners.worker.data_plane:data_plane.py:787 Creating client data channel for localhost:33147 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-12 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-14 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Beam Fn Data client connected. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-15 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-5 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-13 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-4 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-11 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-9 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-17 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-3 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-2 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: getProcessBundleDescriptor request with id 5-16 INFO apache_beam.io.gcp.gcsio:gcsio.py:491 Finished listing 1 files in 0.07973313331604004 seconds. INFO apache_beam.io.filebasedsink:filebasedsink.py:310 Starting finalize_write threads with num_shards: 1 (skipped: 0), batches: 1, num_threads: 1 INFO apache_beam.io.filebasedsink:filebasedsink.py:357 Renamed 1 shards in 0.33 seconds. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient unref INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Closing environment urn: "beam:env:external:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 payload: "\n\021\n\017localhost:44449" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:bytes:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:string_utf8:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:kv:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:bool:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:varint:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:double:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:iterable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:timer:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:interval_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:length_prefix:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:global_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:windowed_value:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:param_windowed_value:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:state_backed_iterable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:custom_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:row:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:sharded_key:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:nullable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:progress_reporting:v0" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:harness_monitoring_infos:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:worker_status:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:combinefn:packed_python:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:version:sdk_base:apache/beam_python3.8_sdk:2.54.0.dev" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:transform:to_string:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:data_sampling:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:288 No more requests from control plane INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:289 SDK Harness waiting for in-flight requests to complete INFO apache_beam.runners.worker.data_plane:data_plane.py:820 Closing all cached grpc data channels. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:929 Closing all cached gRPC state handlers. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:301 Done consuming work. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver onCompleted INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Hanged up for unknown endpoint. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver onCompleted INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Hanged up for unknown endpoint. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:10 PM org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient close INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: Error cleaning up servers urn: "beam:env:external:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 payload: "\n\021\n\017localhost:44449" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:bytes:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:string_utf8:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:kv:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:bool:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:varint:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:double:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:iterable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:timer:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:interval_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:length_prefix:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:global_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:windowed_value:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:param_windowed_value:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:state_backed_iterable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:custom_window:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:row:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:sharded_key:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:coder:nullable:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:progress_reporting:v0" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:harness_monitoring_infos:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:worker_status:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:combinefn:packed_python:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:version:sdk_base:apache/beam_python3.8_sdk:2.54.0.dev" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:transform:to_string:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 capabilities: "beam:protocol:data_sampling:v1" INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 java.lang.IllegalStateException: call already closed INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.grpc.v1p54p0.com.google.common.base.Preconditions.checkState(Preconditions.java:502) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.grpc.v1p54p0.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:219) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.grpc.v1p54p0.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:212) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:395) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.state.GrpcStateService.close(GrpcStateService.java:63) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.sdk.fn.server.GrpcFnServer.close(GrpcFnServer.java:156) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.$closeResource(DefaultJobBundleFactory.java:649) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:649) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:665) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$400(DefaultJobBundleFactory.java:596) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$createEnvironmentCaches$3(DefaultJobBundleFactory.java:213) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1850) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3503) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3479) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3252) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4343) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4960) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.close(DefaultJobBundleFactory.java:326) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext.close(DefaultExecutableStageContext.java:43) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingExecutableStageContextFactory.java:217) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingExecutableStageContextFactory.java:193) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.release(ReferenceCountingExecutableStageContextFactory.java:182) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.scheduleRelease(ReferenceCountingExecutableStageContextFactory.java:136) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.access$300(ReferenceCountingExecutableStageContextFactory.java:48) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.close(ReferenceCountingExecutableStageContextFactory.java:213) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:269) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.close(FlinkExecutableStageFunction.java:374) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:519) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:357) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at java.lang.Thread.run(Thread.java:750) INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO apache_beam.runners.portability.portable_runner:portable_runner.py:550 Job state changed to DONE INFO apache_beam.io.gcp.gcsio:gcsio.py:491 Finished listing 1 files in 0.06665349006652832 seconds. PASSED [ 75%] apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher -------------------------------- live log call --------------------------------- INFO apache_beam.runners.worker.worker_pool_main:worker_pool_main.py:113 Listening for workers at localhost:37985 INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function pack_combiners at 0x7f7b9cc9d790> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function lift_combiners at 0x7f7b9cc9d820> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:712 ==================== <function sort_stages at 0x7f7b9cc9df70> ==================== INFO apache_beam.utils.subprocess_server:subprocess_server.py:203 Starting service with ('java' '-jar' '/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Examples_Flink/src/runners/flink/1.16/job-server/build/libs/beam-runners-flink-1.16-job-server-2.54.0-SNAPSHOT.jar' '--flink-master' '[auto]' '--artifacts-dir' '/tmp/beam-tempxyweclg9/artifactseyarhglv' '--job-port' '58639' '--artifact-port' '0' '--expansion-port' '0') WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:18 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: Unable to retrieve the requested metadata. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver createArtifactStagingService INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: ArtifactStagingService started on localhost:39489 WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:51 PM org.apache.beam.runners.jobsubmission.JobServerDriver createExpansionService INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Java ExpansionService started on localhost:45231 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:54 PM org.apache.beam.runners.jobsubmission.JobServerDriver createJobServer INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: JobService started on localhost:58639 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:54 PM org.apache.beam.runners.jobsubmission.JobServerDriver run INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Job server now running, terminate with Ctrl+C > Task :sdks:python:test-suites:portable:py311:flinkExamples WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:33693. INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:51 PM org.apache.beam.runners.jobsubmission.JobServerDriver createExpansionService INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Java ExpansionService started on localhost:40461 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:54 PM org.apache.beam.runners.jobsubmission.JobServerDriver createJobServer INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: JobService started on localhost:33693 INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 23, 2024 4:58:54 PM org.apache.beam.runners.jobsubmission.JobServerDriver run INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: Job server now running, terminate with Ctrl+C > Task :sdks:python:test-suites:portable:py38:flinkExamples WARNING root:subprocess_server.py:182 Waiting for grpc channel to be ready at localhost:58639. The message received from the daemon indicates that the daemon has disappeared. Build request sent: Build{id=d656a73d-014f-48bf-910c-e5282e7fe95d, currentDir=/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Examples_Flink/src} Attempting to read last messages from the daemon log... FATAL: command execution failed java.io.IOException: Backing channel 'apache-beam-jenkins-13' is disconnected. at hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215) at hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285) at com.sun.proxy.$Proxy185.isAlive(Unknown Source) at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215) at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207) at hudson.Launcher$ProcStarter.join(Launcher.java:524) at hudson.plugins.gradle.Gradle.perform(Gradle.java:321) at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20) at hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:818) at hudson.model.Build$BuildExecution.build(Build.java:199) at hudson.model.Build$BuildExecution.doRun(Build.java:164) at hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:526) at hudson.model.Run.execute(Run.java:1900) at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44) at hudson.model.ResourceController.execute(ResourceController.java:101) at hudson.model.Executor.run(Executor.java:442) Caused by: hudson.remoting.Channel$OrderlyShutdown: Command Close created at at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1313) at hudson.remoting.Channel$1.handle(Channel.java:606) 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:1306) at hudson.remoting.Channel.close(Channel.java:1480) at hudson.remoting.Channel.close(Channel.java:1447) at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1312) at hudson.remoting.Channel$1.handle(Channel.java:606) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81) Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure ERROR: apache-beam-jenkins-13 is offline; cannot locate jdk_1.8_latest --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org