赞
踩
文章目录
SQL 的容错(Checkpoint)
一、Checkpoint介绍
二、Flink 中的数据恢复过程
三、Checkpoint的配置
配置优化
为了使 Flink 的状态具有良好的容错性,Flink 提供了检查点机制 (CheckPoints) 。通过检查点机制,Flink 定期在数据流上生成 checkpoint barrier ,当某个算子收到 barrier 时,即会基于当前