flink检查点简单理解

flink检查点其实有两种实现方式&＃xff1a;
1.朴素算法–数据源暂停接受数据&＃xff0c;待数据流中的数据全部处理完毕&＃xff0c;再把数据源偏移&＃xff0c;键值状态&＃xff0c;算子状态等写入检查点路径中&＃xff0c;优点是实现简单&＃xff0c;缺点是处理太慢
2.基于Chandy-lamport的分布式快照算法–通过在数据源注入特殊检查点标志的记录的方式来进行每个任务的备份&＃xff0c;首先是数据源先备份&＃xff0c;随后是数据处理的算子进行备份&＃xff0c;最后是数据汇算子进行备份。当其中某个任务在备份的时候其他任务是可以进行数据处理的&＃xff0c;所以备份的过程并不会导致数据处理的较大延迟.