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

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

回复可见
**** Hidden Message *****

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 中可以配置不同的状态后端
页: [1]
查看完整版本: Flink 中 exactly-once 语义是如何实现的,状态是如何存储的?