Flink
的一个重大价值在于,
它既保证了
exactly-once
,也具有低延迟和高吞吐
的处理能力
。
1.端到端(End-To-End)状态一致性
端到端的一致性保证,意味着结果的正确性贯穿了整个流处理应用的始终;每
一个组件都保证了它自己的一致性,整个端到端的一致性级别取决于所有组件中一
致性最弱的组件.
具体划分:
1.
内部保证 —— 依赖
checkpoint。
2.source
端 —— 需要外部源可重设数据的读取位置。
3.sink
端 —— 需要保证从故障恢复时,数据不会重复写入外部系统