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

Flink 依靠 checkpoint 机制来实现 exactly-once 语义,如果要实现端到端
的 exactly-once,还需要外部 source 和 sink 满足一定的条件。状态的存储通过状态
后端来管理,Flink 中可以配置不同的状态后端。
标签: flink、语义、sink、状态、端到、面试
  • 回复
隐藏