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
