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

Reply via email to