Flink中的Exactly-Once语义是如何实现的？

　　1、检查点： 定期创建数据流的状态检查点，确保在故障恢复时能够从检查点恢复。

　　2、端到端保证： 与数据源和接收器的集成，确保整个数据处理流程中数据不会丢失也不会被重复处理。

　　3、事务性写入： 在输出端支持事务性写入操作，确保输出的精确一次语义。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群