Flink——容错机制

Flink的容错机制 概述 Flink容错的核心机制就是持续地创建分布式数据流及其状态的一致性快照，。当系统遇到故障时，比如（机器，网络，软件等），重启所有的算子，回退到checkpoint（检查点），确保程序的每一条记录只会作用准确一次(exactly-once )的语义，也可以选择配置成至少一次(at-least-once ) 注意： 为了容错机制生效，数据源（例如 queue 或者 brok

>>阅读原文<<