开发者社区> 问答> 正文

Flink怎么维护Checkpoint?在HDFS上存储的话会有小文件吗?

Flink怎么维护Checkpoint?在HDFS上存储的话会有小文件吗?

展开
收起
xin在这 2021-12-09 18:49:36 837 0
1 条回答
写回答
取消 提交回答
  • 默认情况下,如果设置了Checkpoint选项,Flink只保留最近成功生成的1个Checkpoint。当Flink程序失败时,可以从最近的这个Checkpoint来进行恢复。但是,如果我们希望保留多个Checkpoint,并能够根据实际需要选择其中一个进行恢复,这样会更加灵活。Flink支持保留多个Checkpoint,需要在Flink的配置文件conf/flink-conf.yaml中,添加如下配置指定最多需要保存Checkpoint的个数。

    2021-12-09 18:49:51
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
贺小令|Apache Flink 1.16 简介 立即下载
实时计算Flink版产品新功能介绍 立即下载
海量数据分布式存储——Apache HDFS之最新进展 立即下载