应该是所有operator完成各自的pre-commit，它们会发起一个commit操作，然后才会flush
1193216154 <1193216...@qq.com> 于2020年2月27日周四 下午5:30写道： > 各位大神好，有个困惑。用FlinkKafkaProducer011写kafka的exactly > once，比如我的checkpoint是十分钟，是否在十分钟之内，都不会往kafka下游发送数据。因为我看flink源码，是有在执行snapshotState的时候才kakfa的producer才flush了。
