Re: Savepoint problen on KubernetesOperator HA cluster

2022-08-11 Thread Evgeniy Lyutikov
a Fóra Отправлено: 11 августа 2022 г. 16:25:47 Кому: Evgeniy Lyutikov Копия: user@flink.apache.org Тема: Re: Savepoint problen on KubernetesOperator HA cluster In general the Flink JobManager HA /client mechanism ensures that the rest requests end up at the current leader. In your case it'

Re: Savepoint problen on KubernetesOperator HA cluster

2022-08-11 Thread Gyula Fóra
In general the Flink JobManager HA /client mechanism ensures that the rest requests end up at the current leader. In your case it's not clear what the actual cause of the issue was. What I would do is to upgrade to the latest operator version (1.1.0) where the savepoint upgrade mechanism has been

Savepoint problen on KubernetesOperator HA cluster

2022-08-11 Thread Evgeniy Lyutikov
Hi, I'm using flink 1.14.4 with flink kubernetes operator 1.0.1 with ha configuration on 3 jobmanager. When trying to change the job configuration, it restarts with trigger savepoint and an error occurs each time: 2022-08-10 12:04:21,142 mo.a.f.k.o.c.FlinkDeploymentController [INFO ][job-nam