Apache Flink fault tolerance源码剖析(六)

上篇文章咱们分析了基于检查点的用户状态的保存机制——状态终端。这篇文章咱们来分析barrier（中文常译为栅栏或者屏障，为了不引入名称争议，此处仍用英文表示）。检查点的barrier是提供exactly once一致性保证的主要保证机制。这篇文章咱们会就此展开分析。java 这篇文章咱们侧重于核心代码分析，原理咱们在这个系列的第一篇文章《Flink数据流的Fault Tolerance机制》web

>>阅读原文<<