??????1??????????????mysql-connector-java??latest???? ??????????5.1.6?????????????????? ????5.1.48???????? <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.48</version> </dependency>
------------------ ???????? ------------------ ??????: "LakeShen"<shenleifight...@gmail.com>; ????????: 2019??12??26??(??????) ????11:35 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: Flink????Kafka??Mysql?? End-To-End Exactly-Once???????????? ?????????????????????????? ?????????????? 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????????????????????????????????????????????????????????
