See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1769/display/redirect>
Changes:
------------------------------------------
[...truncated 39.08 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
20b3bd0c-f2ea-4bec-a7d0-172e3102b5df, BeamApp-jenkins-0427035659-8a12c7b2,
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
20b3bd0c-f2ea-4bec-a7d0-172e3102b5df, BeamApp-jenkins-0427035659-8a12c7b2,
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
unref
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Closing environment urn: "beam:env:external:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 payload:
"\n\021\n\017localhost:37635"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bytes:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:string_utf8:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:kv:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bool:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:varint:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:double:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:timer:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:interval_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:length_prefix:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:global_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:param_windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:state_backed_iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:custom_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:row:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:sharded_key:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:nullable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:progress_reporting:v0"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:harness_monitoring_infos:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:worker_status:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:combinefn:packed_python:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.48.0.dev"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:to_string:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:data_sampling:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Hanged up for unknown endpoint.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Error cleaning up servers urn: "beam:env:external:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 payload:
"\n\021\n\017localhost:37635"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bytes:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:string_utf8:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:kv:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bool:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:varint:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:double:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:timer:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:interval_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:length_prefix:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:global_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:param_windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:state_backed_iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:custom_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:row:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:sharded_key:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:nullable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:progress_reporting:v0"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:harness_monitoring_infos:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:worker_status:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:combinefn:packed_python:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.48.0.dev"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:to_string:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:data_sampling:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
java.lang.IllegalStateException: call already closed
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 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:126 at
org.apache.beam.vendor.grpc.v1p54p0.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:219)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.grpc.v1p54p0.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:212)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 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:126 at
org.apache.beam.runners.fnexecution.state.GrpcStateService.close(GrpcStateService.java:63)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.server.GrpcFnServer.close(GrpcFnServer.java:156)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.$closeResource(DefaultJobBundleFactory.java:643)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:643)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:659)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$400(DefaultJobBundleFactory.java:590)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$createEnvironmentCaches$3(DefaultJobBundleFactory.java:213)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1809)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3462)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3438)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3215)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4270)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4909)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.close(DefaultJobBundleFactory.java:320)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext.close(DefaultExecutableStageContext.java:43)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingExecutableStageContextFactory.java:217)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingExecutableStageContextFactory.java:193)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.release(ReferenceCountingExecutableStageContextFactory.java:182)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.scheduleRelease(ReferenceCountingExecutableStageContextFactory.java:136)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.access$300(ReferenceCountingExecutableStageContextFactory.java:48)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.close(ReferenceCountingExecutableStageContextFactory.java:213)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:269)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.close(FlinkExecutableStageFunction.java:374)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:519)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:357)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
INFO apache_beam.runners.worker.statecache:statecache.py:234 Creating state
cache with size 0
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:187 Creating
insecure control channel for localhost:38571.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:195 Control
channel established.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:243 Initializing
SDKHarness with unbounded number of workers.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Beam Fn Control client connected with id 4-1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-4
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:889 Creating
insecure state channel for localhost:38337.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:896 State channel
established.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-7
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-15
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-11
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-2
INFO apache_beam.runners.worker.data_plane:data_plane.py:772 Creating
client data channel for localhost:42999
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-16
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM org.apache.beam.runners.fnexecution.data.GrpcDataService data
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Beam Fn Data client connected.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-14
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-13
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-12
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-17
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-6
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-9
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-3
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-10
INFO apache_beam.io.gcp.gcsio:gcsio.py:649 Finished listing 1 files in
0.06996703147888184 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 4-5
INFO apache_beam.io.filebasedsink:filebasedsink.py:316 Starting
finalize_write threads with num_shards: 1 (skipped: 0), batches: 1,
num_threads: 1
INFO apache_beam.io.filebasedsink:filebasedsink.py:360 Renamed 1 shards in
0.41 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:15 AM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
unref
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Closing environment urn: "beam:env:external:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 payload:
"\n\021\n\017localhost:37635"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bytes:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:string_utf8:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:kv:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:bool:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:varint:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:double:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:timer:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:interval_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:length_prefix:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:global_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:param_windowed_value:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:state_backed_iterable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:custom_window:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:row:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:sharded_key:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:coder:nullable:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:progress_reporting:v0"
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:272 No more
requests from control plane
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:harness_monitoring_infos:v1"
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:273 SDK Harness
waiting for in-flight requests to complete
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:worker_status:v1"
INFO apache_beam.runners.worker.data_plane:data_plane.py:805 Closing all
cached grpc data channels.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:combinefn:packed_python:v1"
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:908 Closing all
cached gRPC state handlers.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.48.0.dev"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:285 Done consuming
work.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:transform:to_string:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
capabilities: "beam:protocol:data_sampling:v1"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:15 AM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Hanged up for unknown endpoint.
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:590
Job state changed to DONE
INFO apache_beam.io.gcp.gcsio:gcsio.py:649 Finished listing 1 files in
0.0424196720123291 seconds.
PASSED [ 73%]
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:42907
INFO root:environments.py:376 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.48.0.dev
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function pack_combiners at 0x7f551625b050>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function lift_combiners at 0x7f551625b0e0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function sort_stages at 0x7f551625b830>
====================
INFO apache_beam.utils.subprocess_server:subprocess_server.py:116 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.48.0-SNAPSHOT.jar'
'--flink-master' '[auto]' '--artifacts-dir'
'/tmp/beam-temptky00s9_/artifactshmg1y7tu' '--job-port' '50149'
'--artifact-port' '0' '--expansion-port' '0']
WARNING root:subprocess_server.py:98 Waiting for grpc channel to be ready at
localhost:50149.
WARNING root:subprocess_server.py:98 Waiting for grpc channel to be ready at
localhost:50149.
WARNING root:subprocess_server.py:98 Waiting for grpc channel to be ready at
localhost:50149.
WARNING root:subprocess_server.py:98 Waiting for grpc channel to be ready at
localhost:50149.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 27,
2023 3:57:26 AM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Unable to retrieve the requested metadata.
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-6' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy135.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:814)
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:522)
at hudson.model.Run.execute(Run.java:1896)
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: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-6 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
