Hi, > 在 2020年12月7日，16:46，[email protected] 写道： > > flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交； > 自己实现sink开启数据库事务，遇到错误回滚并抛出异常，是否可以实现数据精确一次
Flink 写入关系型数据库是可以做到端到端的一致性的，默认是不支持的，需要实现两阶段提交，按照你的思路是可行的。另外社区也有人在做这个feature[1]，已经有PR了，你可以参考，预计会在1.13里支持。 祝好， Leonard [1] https://issues.apache.org/jira/browse/FLINK-15578 <https://issues.apache.org/jira/browse/FLINK-15578>
