Actually we figured it out. We need to configure High Availability mode to
recover jobs during new kubernetes deployment.
On Tue, Oct 5, 2021 at 11:39 AM Sharon Xie wrote:
> Hi,
>
> I'm currently running Flink 1.13.2 using kubernetes session mode - native
> kubernetes. When I update the job mana
Hi,
I'm currently running Flink 1.13.2 using kubernetes session mode - native
kubernetes. When I update the job manager deployment through `kubectl apply
flink-jobmanager-deployment.yaml`, a new job manager pod is created. I'd
expect all the task manager pods will re-register with the new JM pod.