Flink 原理与实现: Flink的状态编程和容错机制之状态一致性

2022-02-14

字数统计: 206字 | 阅读时长≈ 1分

Flink状态一致性

当在分布式系统中引入状态时，自然也会导致一系列的问题.如:

一致性问题.

什么叫一致性问题呢?

就是不管你这个任务是失败了,还是中间出错了,还是暂停了,还是重复启动了.我要保证所有数据,不管在那种情况下发生,数据都是准确的或者说结果一定是准确的.这就叫所谓的状态一致.

你要想保证结果准确,首先你就要保证的就是状态一致.所以状态一致就是为了保证最后结果的准确.

一致性的级别在我们Flink中分为三种.

一致性(级别分为3种)

端到端（end-to-end）状态一致性

如下图所示:

本文作者： xubatian
本文链接： http://xubatian.cn/Flink-原理与实现-Flink的状态编程和容错机制之状态一致性/
版权声明： 本博客所有文章除特别声明外均为原创，采用 CC BY 4.0 CN协议许可协议。转载请注明出处:https://www.xubatian.cn/

jsonContent: meta: false pages: false posts: title: true date: true path: true text: false raw: false content: false slug: false updated: false comments: false link: false permalink: false excerpt: false categories: false tags: true