Re: New session mode job manager deployment rejected existing task managers

2021-10-05 Thread Sharon Xie
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

New session mode job manager deployment rejected existing task managers

2021-10-05 Thread Sharon Xie
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.