1.????K8s??HA????????????????????????????configMap. configMap??????: cluster-id-00000000000000000000000000000000-config-map.????????????????????jobgraph??checkpoint????????????????????????????????high-availability.storageDir?????????? 2.??Application??????????????Id??????????00000000000000000000000000000000??????????????????????????????????????????????????????????????checkpoint,??????????????????????????????????????????????HA?????????????????????????????? 3.????????????????????????????flink cancel.stop????????????????????????????deployment??????????????configMap??????????????????????????????????????????????????checkpoint????????????????????????????????????????????
???????????????????? [1].https://flink.apache.org/2021/02/10/native-k8s-with-ha.html [2].https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink [3].https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/ha/kubernetes_ha/#high-availability-data-clean-up Best, Hjw ------------------ ???????? ------------------ ??????: "user-zh" <casel_c...@126.com>; ????????: 2022??8??28??(??????) ????11:49 ??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>; ????: k8s??????application????flink????HA?????????????? k8s??????????????HA????????JM??????????????????????JM????????????????????????????????????????????checkpoint????????????????