2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,580 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remoting shut down.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,574 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remoting shut down.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,469 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,383 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,384 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,383 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2023-08-16T11:05:04+02:00	2023-08-16 09:05:04,377 INFO  akka.actor.CoordinatedShutdown                               [] - Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
2023-08-16T11:05:03+02:00	2023-08-16 09:05:03,732 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Close ResourceManager connection 318d4e3f6341c2e6d8ba71acec2e3caf.
2023-08-16T11:05:03+02:00	2023-08-16 09:05:03,732 INFO  org.apache.flink.runtime.io.disk.FileChannelManagerImpl      [] - FileChannelManager removed spill file directory /tmp/flink-io-77cf25f4-d840-4948-850c-8d0f99fca31c
2023-08-16T11:05:03+02:00	2023-08-16 09:05:03,732 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Stopping TaskExecutor akka.tcp://[EMAIL REDACTED:b990e736cea20590059709faae10f4309ee0c241fb37cb8d90f00be173eb63e2]:6122/user/rpc/taskmanager_0.
2023-08-16T11:05:03+02:00	2023-08-16 09:05:03,729 INFO  org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager [] - Shutting down TaskExecutorLocalStateStoresManager.
2023-08-16T11:05:03+02:00	{"metadata":{"name":"pyflink-batch-job-queued-orders-liza-taskmanager-1-4.177bd1bf1a666f8c","namespace":"franz-shadow","uid":"1d559280-5cdd-440c-957f-747d66055062","resourceVersion":"10061061142","creationTimestamp":"2023-08-16T09:05:03Z","managedFields":[{"manager":"kubelet","operation":"Update","apiVersion":"v1","time":"2023-08-16T09:05:03Z","fieldsType":"FieldsV1","fieldsV1":{"f:count":{},"f:firstTimestamp":{},"f:involvedObject":{},"f:lastTimestamp":{},"f:message":{},"f:reason":{},"f:source":{"f:component":{},"f:host":{}},"f:type":{}}}]},"involvedObject":{"kind":"Pod","namespace":"franz-shadow","name":"pyflink-batch-job-queued-orders-liza-taskmanager-1-4","uid":"d2c353ca-7013-4e50-bd2f-9832db1da748","apiVersion":"v1","resourceVersion":"10056315953","fieldPath":"spec.containers{flink-main-container}"},"reason":"Killing","message":"Stopping container flink-main-container","source":{"component":"kubelet","host":"ip-xx-xx-xx-xx.eu-west-1.compute.internal"},"firstTimestamp":"2023-08-16T09:05:03Z","lastTimestamp":"2023-08-16T09:05:03Z","count":1,"type":"Normal","eventTime":null,"reportingComponent":"","reportingInstance":""}
2023-08-16T11:05:03+02:00	2023-08-16 09:05:03,728 INFO  org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner [] - RECEIVED SIGNAL 15: SIGTERM. Shutting down as requested.
2023-08-16T09:14:41+02:00	2023-08-16 07:14:41,402 INFO  org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService [] - getProcessBundleDescriptor request with id 4-2
2023-08-16T09:14:40+02:00	2023-08-16 07:14:40,395 INFO  org.apache.beam.runners.fnexecution.data.GrpcDataService     [] - Beam Fn Data client connected.