Flink的容错机制第二篇 异步栅栏快照机制

上一篇讲到Flink是基于有状态的运算，而避免了传统流计算缺少程序状态支持的数据存储，访问，动态扩容，数据库回滚一致性等问题。这一篇主要讲Flink如何通过状态管理而做到流计算中的消息传输保障。 一，一致性与全局状态 在分布式系统中，运行着多个相互关联的服务节点。 一致性是指分布式系统中的多个服务节点，给定一系列的操作，在约定协议的保障下，使它们对外界呈现的状态是一致的。换句话说，也就是保证集群中

>>阅读原文<<