See
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/6676/display/redirect>
Changes:
------------------------------------------
[...truncated 27.91 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Clearing resource requirements of job 633163a276435230fc420371c971df0c
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.executiongraph.DefaultExecutionGraph
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job
BeamApp-jenkins-0513015342-f59e5ed1 (633163a276435230fc420371c971df0c) switched
from state RUNNING to FINISHED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down Flink Mini Cluster
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedTerminalState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job
633163a276435230fc420371c971df0c reached terminal state FINISHED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.TaskExecutor onStop
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping TaskExecutor akka://flink/user/rpc/taskmanager_0.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$registerGloballyTerminatedJobInJobResultStore$30
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job
633163a276435230fc420371c971df0c has been registered for cleanup in the
JobResultStore after reaching a terminal state.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeResourceManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Close ResourceManager connection ca1b054af5ab8a1432241b9a0a06ed37.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.resourcemanager.ResourceManager
closeTaskManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Closing TaskExecutor connection 4511f9c1-6bcd-445d-935e-0b48f11f57c2 because:
The TaskExecutor is shutting down.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
disconnectJobManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Close JobManager connection for job 633163a276435230fc420371c971df0c.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.jobmaster.JobMaster onStop
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping the JobMaster for job 'BeamApp-jenkins-0513015342-f59e5ed1'
(633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down rest endpoint.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager
shutdown
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down TaskExecutorStateChangelogStoragesManager.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
d92d4e9e36084edb06374c1ec0a6e7ed, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
f9ca2d52106e0e149718e71ca573ccb2, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
f8ea1548db9321793469df6c0c2e2eea, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.jobmaster.JobMaster
disconnectTaskManager
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Disconnect TaskExecutor 4511f9c1-6bcd-445d-935e-0b48f11f57c2 because: The
TaskExecutor is shutting down.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
ec8adeebb0c8690f6d36182e3c00edd4, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
673a9eadd7ff8bfa82dc1b140e2a74fc, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [d92d4e9e36084edb06374c1ec0a6e7ed].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
ed8aeb5c89d2ead7be7b076d519205b9, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
0a5ea007747aec3adf82ffef4637adf3, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
7baf40a5663c0c418d1d47de6cefdbe8, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [f9ca2d52106e0e149718e71ca573ccb2].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
92716257515d11f58e258fbfb08f79af, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
d7b66d04f96bfa712f8e881830760abd, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [f8ea1548db9321793469df6c0c2e2eea].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
7d78d953c5394e4b30e739d3c9b4fa6c, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
acf45aeaa76e33e51c31f953cd9a76db, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [ec8adeebb0c8690f6d36182e3c00edd4].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
cece9e65805587210c07d2d47ce76572, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [673a9eadd7ff8bfa82dc1b140e2a74fc].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
d991242d19f050156d27d287a6326330, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [ed8aeb5c89d2ead7be7b076d519205b9].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
40f137cb1a4b43cd780d694bbe8d0d0b, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
freeSlotInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes),
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId:
75efbb9dca0781bd2e7fef13c010b0aa, jobId: 633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [0a5ea007747aec3adf82ffef4637adf3].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [7baf40a5663c0c418d1d47de6cefdbe8].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [92716257515d11f58e258fbfb08f79af].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [d7b66d04f96bfa712f8e881830760abd].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [7d78d953c5394e4b30e739d3c9b4fa6c].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [acf45aeaa76e33e51c31f953cd9a76db].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [cece9e65805587210c07d2d47ce76572].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [d991242d19f050156d27d287a6326330].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [40f137cb1a4b43cd780d694bbe8d0d0b].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Releasing slot [75efbb9dca0781bd2e7fef13c010b0aa].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Close ResourceManager connection ca1b054af5ab8a1432241b9a0a06ed37: Stopping
JobMaster for job 'BeamApp-jenkins-0513015342-f59e5ed1'
(633163a276435230fc420371c971df0c).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$7
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Removing cache directory /tmp/flink-web-ui
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Disconnect job manager
a2ccd50c32a2f9cf6c23068396d24a60@akka://flink/user/rpc/jobmanager_3 for job
633163a276435230fc420371c971df0c from the resource manager.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService
stop
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stop job leader service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rest.RestServerEndpoint
lambda$closeAsync$1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shut down complete.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down TaskExecutorLocalStateStoresManager.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.resourcemanager.ResourceManager
deregisterApplication
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shut down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
closeAsyncInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Closing components.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FileChannelManager removed spill file directory
/tmp/flink-io-312bc64b-67fe-4452-a5f5-813be00bdabe
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment
close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down the network environment and its components.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
closeInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping SessionDispatcherLeaderProcess.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FileChannelManager removed spill file directory
/tmp/flink-netty-shuffle-a23eb881-65fc-49a5-b607-ff31d96c53c5
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping dispatcher akka://flink/user/rpc/dispatcher_2.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateRunningJobs
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping all currently running jobs of dispatcher
akka://flink/user/rpc/dispatcher_2.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl closeAsync
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping resource manager service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down the kvState service and its components.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService
stop
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stop job leader service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Closing the slot manager.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
suspend
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Suspending the slot manager.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
removed file cache directory
/tmp/flink-dist-cache-b4688263-6ac4-42b0-9ddc-381f862deb76
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
handleOnStopException
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopped dispatcher akka://flink/user/rpc/dispatcher_2.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping Akka RPC service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopping Akka RPC service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopped Akka RPC service.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down BLOB cache
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Shutting down BLOB cache
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.blob.BlobServer close
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopped BLOB server at 0.0.0.0:45175
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 May 13,
2023 1:54:07 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Stopped Akka RPC service.
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:590
Job state changed to DONE
PASSED [100%]
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner
self.run()
File "/usr/lib/python3.7/threading.py", line 870, in run
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
line 669, in <lambda>
target=lambda: self._read_inputs(elements_iterator),
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
line 652, in _read_inputs
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
line 475, in __next__
=============================== warnings summary ===============================
../../build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py:15
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py>:15:
DeprecationWarning: the imp module is deprecated in favour of importlib; see
the module's documentation for alternative uses
from imp import load_source
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
line 881, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.CANCELLED
details = "Multiplexer hanging up"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:42103 {created_time:"2023-05-13T01:54:07.200476944+00:00",
grpc_status:1, grpc_message:"Multiplexer hanging up"}"
>
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:121
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:121:
DeprecationWarning: pkg_resources is deprecated as an API
warnings.warn("pkg_resources is deprecated as an API", DeprecationWarning)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2870:
18 warnings
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:2870:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
declare_namespace(pkg)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2870:
13 warnings
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:2870:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google.cloud')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
declare_namespace(pkg)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2349
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2349
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2349
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2349
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:2349:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
declare_namespace(parent)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2870
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:2870:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google.logging')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
declare_namespace(pkg)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py:2870
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/pkg_resources/__init__.py>:2870:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google.iam')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
declare_namespace(pkg)
../../build/gradleenv/2022703441/lib/python3.7/site-packages/google/rpc/__init__.py:20
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/google/rpc/__init__.py>:20:
DeprecationWarning: Deprecated call to
`pkg_resources.declare_namespace('google.rpc')`.
Implementing implicit namespace packages (as specified in PEP 420) is
preferred to `pkg_resources.declare_namespace`. See
https://setuptools.pypa.io/en/latest/references/keywords.html#keyword-namespace-packages
pkg_resources.declare_namespace(__name__)
-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file:
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/sdks/python/pytest_postCommitIT-flink-py37.xml>
-
================== 7 passed, 40 warnings in 260.12s (0:04:20) ==================
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_PostCommit_Python37/ws/src/sdks/python/build.gradle'>
line: 96
* What went wrong:
Execution failed for task ':sdks:python:bdistPy37linux'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 1 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 33m 57s
211 actionable tasks: 207 executed, 4 up-to-date
Publishing build scan...
https://ge.apache.org/s/vtyj3mz43mcfq
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
