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 才能正常运行