Flink中的Exactly-Once如何实现？

　　1、检查点（Checkpointing）： 通过定期检查点来保持状态的一致性。

　　2、幂等性操作： 确保作业的操作是幂等的，即多次执行相同操作的结果是一样的。

　　3、事务性接收器： 使用支持事务的接收器，确保数据只提交一次。

很赞哦！

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