版本：1.13.3
lib目录下：
-rw-r--r-- 1 root root 7759243 Aug 12 10:12
flink-connector-hive_2.12-1.13.3.jar
-rw-r--r-- 1 root root 92313 Aug 12 10:12 flink-csv-1.13.3.jar
-rw-r--r-- 1 root root 106535831 Aug 12 10:12 flink-dist_2.12-1.13.3.jar
-rw-r--r-- 1 root root 78644 Aug 12 10:12
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.
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 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
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
