我参考你的代码，也遇到了同样的问题，有什么好的方法吗？
hdxg1101300...@163.com
发件人： 卢伟楠
发送时间： 2020-01-03 15:18
收件人： user-zh
主题： Re: Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题
我发这个用于测试的代码，里面的mysql-connector-java已经是最新的了，由于使用mysql-connector-java老版本趟过的坑已经处理过一遍了
> 在 2020年1月3日，下午3:13，残翅2008 <770968...@qq.c
--- 原始邮件 --
> 发件人: "LakeShen" 发送时间: 2019年12月26日(星期四) 中午11:35
> 收件人: "user-zh"
> 主题: Re: Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题
>
>
>
> 是否可以尝试使用幂等来解决 端到端的一致性
>
> Best wishes，
> 沈磊
>
> 卢伟楠
> > 各位大
是否可以尝试使用幂等来解决 端到端的一致性
Best wishes，
沈磊
卢伟楠 于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.ap
各位大佬好：
最近是实现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.stre
