Flink 通过实现两阶段提交和状态保存来实现端到端的一致性语义。

• 开始事務（beginTransaction）创建一个临时文件夹来写把数据写入到这个文件夹里面。
• 预提交（preCommit）将内存中缓存的数据写入文件并关闭
• 正式提交（commit）将之前寫完的临时文件放入目标目录下。这代表着最终的数据会有一些延迟
• 丢弃（abort）丢弃临时文件。

若失败发生在预提交成功后正式提交前。可以根据状态来提交预提交的数据也可删除预提交的数据。