可以看下这两份材料 * https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/fault-tolerance/checkpointing/ * https://zhuanlan.zhihu.com/p/102607983
其实就是 Flink 里 Exactly-once 的实现方式，简单说来就是分布式快照批量提交，上游数据可以回放。 Best, tison. m18814122325 <[email protected]> 于2022年7月30日周六 14:22写道： > > 在Storm中会有ack机制来保证消息是否被下个算子是否被处理，那么请问在Flink框架内部中上游算子通过Netty发送消息到下游时，如何做到消息不会因为网络原因等各种异常情况产生丢失情况？ > > 谢谢
