configmap 如下
sql-test-00000000000000000000000000000000-jobmanager-leader
sql-test-resourcemanager-leader
sql-test-restserver-leader
sql-test-dispatcher-leader



在 2022-06-08 15:42:52,"json" <18042304...@163.com> 写道:

flink1.13.6 on k8s application 模式,设置HA
high-availability: 
org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory 
high-availability.storageDir: oss
会在 k8s 上生成configmap


1. 但在 k8s 删除此任务的 deployment 后,为什么这些configmap还在?(任务都删了,这些ha应该不需要了吧)
2. 任务重新启动后,还是会去这些 configmap 读ha配置,这个逻辑也很奇怪,任务重启,为什么要去读之前HA信息

为什么会关注这个,因为碰到一个问题:
任务重启报错,找不到 /high-availability.storageDir/task/completedCheckpointe5c125ad20ea 
文件,
但oss 是有文件 
/high-availability.storageDir/task/completedCheckpointe/completedCheckpointacdfb4309903
导致我任务一直报错;删除 上面的configmap 才能正常运行





 

Reply via email to