文档首页/ MapReduce服务 MRS/ 组件操作指南（LTS版）/ 使用Flink/ 管理FlinkServer作业/ 配置FlinkServer作业运行残留信息自动清理
更新时间：2024-08-16 GMT+08:00
查看PDF
分享

配置FlinkServer作业运行残留信息自动清理

操作场景

Flink任务异常停止时会在ZooKeeper、HDFS中残留目录，开启FlinkServer目录残留清理功能可以清理残留目录。

配置作业残留信息自动清理步骤

  1. 登录Manager页面。
  2. 选择“集群 > 服务 > Flink > 配置 > 全部配置”，搜索参数“ClearUpEnabled”并将值设置为“true”开启目录残留清理功能，相关参数详情请见表1。

    表1 FlinkServer目录残留清理参数

    参数

    描述

    默认值

    取值范围

    ClearUpEnabled

    FlinkServer是否开启目录残留清理功能。

    true

    true、false

    ClearUpPeriod

    FlinkServer残留目录清理周期。单位：分钟

    1440

    1440~2147483647

    TrashDirectoryRetentionPeriod

    FlinkServer保留残留目录的周期。单位：分钟

    10080

    10080~2147483647

  3. 配置完成后，单击左上角“保存”并确定保存。

    • 该特性只会清理ZooKeeper的“/flink_base”目录和HDFS的“/flink/recovery”目录下的残留目录，用户自定义修改的目录不会清理。
    • HDFS中的“checkpoints”目录需用户手动删除，该特性不会删除。