是否可以尝试使用幂等来解决 端到端的一致性 Best wishes， 沈磊
卢伟楠 <glusec...@gmail.com> 于2019年12月25日周三 下午4:09写道： > 各位大佬好： > > 最近是实现Kafka到Mysql的 End-To-End Exactly-Once中遇到以下2个问题： > 1：com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: > Communications link failure during commit(). Transaction resolution unknown. > 2：org.apache.flink.streaming.runtime.tasks.TimerException: > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: > Could not forward element to next operator > > 已经做了一个最简单的复现问题的demo，求指教 > git clone https://github.com/lusecond/flink_help --depth=1 > > > 测试过程中，发现继承TwoPhaseCommitSinkFunction类的4个重写方法beginTransaction、preCommit、commit、abort > 分别在不同的线程工作，怀疑过因为线程切换导致jdbc的事务提交出问题，已经做过相关测试排除不是由此引起的问题
