Hi Yuriy,
How do you set your TaskMananger Memory? I think 40MB is not significant high
for Flink. And It’s normal to see memory increase if you have more parallelism
or set another metrics on. You can try setting larger moratory for Flink as
explained by following documents.
https://nightlie
Thanks for your reply
I update operator to version 1.1.0 and nothing has changed
2022-08-11 11:56:48,414 o.a.f.k.o.r.d.AbstractJobReconciler [INFO
][job-namespace/job-namespace] Upgrading/Restarting running job, suspending
first...
2022-08-11 11:56:48,414 o.a.f.k.o.r.d.AbstractJobReconciler [IN
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
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