Flink 如何保证exactly-once?

Flink事务写有两种实现:预写日志(Write-Ahead-Log,WAL)和两阶段提交(Two-Phase-Commit,2PC,需要外部系统支持事务)

此外:Source需要支持重发功能,Sink需要支持幂等写或事务写。

标签: 事务、flink、预写、ahead、phase、面试
  • 回复
隐藏