Re: 请教二阶段提交问题

> 可是再次提交没有意义啊，没有数据[捂脸哭] 这个事儿是这样的，你用 checkpoint 之后呢没有反过来确认的 commit 会留在 state 里，所以重启的时候重新加载 state 的时候就会再提交一遍。然后向 kafka 这一类存储 commit offset 是幂等的，发现已经 commit 过就跳过就 OK 了。 Best, tison. 蒋佳成(Jiacheng Jiang) <920334...@qq.com> 于2020年9月26日周六 下午4:01写道： > >

Re: 请教二阶段提交问题

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