·Flink的容错机制是制作分布式数据流和操作算子状态的一致性快照。快照充当一致性checkpoint，系统可以在发生故障时回滚。
·barriers在数据流源处被注入并行数据流中。然后barriers向下游流动，一旦sink操作算子从其所有输入流接收到barriers n，它就向checkpoint协调器确认快照n完成。
标签：
笔试题
刷题
简历模板
AI算法
大数据
内推
内推：
