Re: 请教二阶段提交问题

时间: 2020年9月25日(星期五) 中午11:14 > 收件人: "user-zh" 主题: 请教二阶段提交问题 > > > > 各位大佬，请教一下二阶段提交的问题，preCommit预提交失败回滚已经很清楚了，就是在commit阶段提交如果失败会怎么，比较迷惑。 > > > > 我自己测试了一下，发现只要是commit失败会造成数据丢失，但是看了下方法注释，说是失败了后会重启flink恢复到最近的state，继续提交，可是我在程序里有专门打印source输入的流数据，发现没有按到任何数据进入，也就是说flink重启后

Re: 请教二阶段提交问题

需要搭配事务性存储机制来使用，能够保证预提交成功的数据能最终被commit成功。 详情可以参考孙金城老师关于这一部分的讲解和代码实现[1] [1]https://www.bilibili.com/video/BV1yk4y1z7Lr?p=33 高亮 于2020年9月25日周五 上午11:14写道： > 各位大佬，请教一下二阶段提交的问题，preCommit预提交失败回滚已经很清楚了，就是在commit阶段提交如果失败会怎么，比较迷惑。 > > > >