??????k8s??????application????flink????HA??????????????

[hjw]

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&gt;;
????????:&nbsp;2022??8??28??(??????) ????11:49
??????:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;

????:&nbsp;k8s??????application????flink????HA??????????????



k8s??????????????HA????????JM??????????????????????JM????????????????????????????????????????????checkpoint????????????????