Hi Alexey, I might be wrong (I don't know this side of Flink very well), but as far as I know JobGraph is never stored in the ZK. It's always recreated from the job's JAR. So you should be able to upgrade the job by replacing the JAR with a newer version, as long as the operator UIDs are the same before and after the upgrade (for operator state to match before and after the upgrade).
Best, Piotrek czw., 20 sie 2020 o 06:34 Alexey Trenikhun <yen...@msn.com> napisał(a): > Hello, > > Let's say I run Flink Job cluster with persistent storage and Zookeeper HA > on k8s with single JobManager and use externalized checkpoints. When JM > crashes, k8s will restart JM pod, and JM will read JobId and JobGraph from > ZK and restore from latest checkpoint. Now let's say I want to upgrade job > binary, I delete deployments, create new deployments referring to newer > image, will JM still read JobGraph from ZK or will create new one from new > job jar? > > Thanks, > Alexey >
