Flink 中 exactly-once 语义是如何实现的，状态是如何存储的？

测试积点老人 · 发表于 2023-11-8 09:19:47

回复可见

游客，如果您要查看本帖隐藏内容请回复

kallinr · 发表于 2023-11-9 09:07:03

学习了

海海豚 · 发表于 2023-11-9 09:21:57

Flink 依靠 checkpoint 机制来实现 exactly-once 语义，如果要实现端到端的 exactly-once，还需要外部 source 和 sink 满足一定的条件。状态的存储通过状态后端来管理，Flink 中可以配置不同的状态后端

qqq911 · 发表于 2023-11-9 10:15:20

Flink 依靠 checkpoint 机制来实现 exactly-once 语义，如果要实现端到端的 exactly-once，还需要外部 source 和 sink 满足一定的条件。状态的存储通过状态后端来管理，Flink 中可以配置不同的状态后端

bellas · 发表于 2023-11-9 10:32:26

Flink 依靠 checkpoint 机制来实现 exactly-once 语义，如果要实现端到端的 exactly-once，还需要外部 source 和 sink 满足一定的条件。状态的存储通过状态后端来管理，Flink 中可以配置不同的状态后端

jingzizx · 发表于 2023-11-9 10:40:02

Flink 依靠 checkpoint 机制来实现 exactly-once 语义，如果要实现端到端的 exactly-once，还需要外部 source 和 sink 满足一定的条件。状态的存储通过状态后端来管理，Flink 中可以配置不同的状态后端

		自动登录	找回密码
密码			(注-册)加入51Testing

站长推荐 /1