Hi, We have configured jobmanager HA with flink 1.12.1 on the k8s environment. We have implemented a HA solution using Native K8s HA solution ( https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink). We have used deployment controller for both jobmanager & taskmanager pods.
So whenever a leader jobmanager crashes and the same jobmanager becomes leader again then everything works fine but whenever a leader jobmanager crashes and some other standby jobmanager becomes leader then metric count gets reset and it starts the request count again from 1. Is it the expected behaviour ? or is there any specific configuration required so that even if the leader jobmanager changes then instead of resetting the metric count it continues the count. Regards, Amit