开发者社区> 问答> 正文

flink1.12.0 HA on k8s native运行一段时间后的问题

大家好,我使用native k8s方式部署flink1.12  HA到k8s一段时间后,jobmanager-leader产生了大量的ConfigMap,这些ConfigMaps都是正常需要的吗?大家都是如何清理和维护的呢?*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:53:19 680 0
1 条回答
写回答
取消 提交回答
  • 你用的是Session模式还是Application模式 ?

    • 如果是Application模式,那在flink job达到terminal state(FAILED, CANCELED, 

    SUCCEED)时会自动清理掉所有HA相关的ConfigMap,你可以在webui上面cancel任务或者用flink 

    cancel,然后观察一下,应该不会有残留的 

    如果是Session模式,你提交了很多任务,每个job都会对应一个ConfigMap的,这个ConfigMap的内容会在任务结束以后清理,但ConfigMap还存在,已经有一个ticket[1]来跟进Session模式下改进清理的过程,目前你可以在Session确认不使用的情况下用命令kubectl 

    delete cm --selector='app= ,configmap-type=high-availability'来清理 

    [1]. https://issues.apache.org/jira/browse/FLINK-20219*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:02:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载

相关镜像