Flink 通过实现两阶段提交和状态保存来实现端到端的一致性语义。分为以下几个步骤：开始事务（beginTransaction）创建一个临时文件夹，来写把数据写入到这个文件夹里面 预提交（preCommit）将内存中缓存的数据写入文件并关闭 正式提交（commit）将之前写完的临时文件放入目标目录下。这代表着最终的数据会有一些延迟 丢弃（abort）丢弃临时文件若失败发生在预提交成功后，正式提交前。可以根据状态来提交预提交的数据，也可删除预提交的数据
发布者：admin，如若转载，请注明出处：https://ai1024.vip/36666.html
赞 (0)
admin
Flink 的重启策略了解吗
« 上一篇
2023年11月30日 am3:23
如果下级存储不支持事务，Flink 怎么保证 exactly-once
下一篇 »
2023年11月30日 am3:23
