MySQL2阶段提交报异常这个是啥问题？

来源：11-11 Flink两阶段提交

慕粉3700508

2021-08-26

com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Communications link failure during commit(). Transaction resolution unknown.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:425)
at com.mysql.jdbc.Util.getInstance(Util.java:408)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:919)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:898)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:887)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:861)
at com.mysql.jdbc.ConnectionImpl.commit(ConnectionImpl.java:1559)
at com.imooc.flink.utils.MySQLUtil.commit(MySQLUtil.java:50)
at com.imooc.flink.sink.MySqlTwoPhaseCommitSinkV1.commit(MySqlTwoPhaseCommitSinkV1.java:83)
at com.imooc.flink.sink.MySqlTwoPhaseCommitSinkV1.commit(MySqlTwoPhaseCommitSinkV1.java:17)
at org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.notifyCheckpointComplete(TwoPhaseCommitSinkFunction.java:282)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.notifyCheckpointComplete(AbstractUdfStreamOperator.java:130)
at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:99)
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:330)
at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1141)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync $10 (S t r e a m T a s k . j a v a : 1106) a t o r g . a p a c h e . f l i n k . s t r e a m i n g . r u n t i m e . t a s k s . S t r e a m T a s k . l a m b d a$ notifyCheckpointOperation$12(StreamTask.java:1129)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:661)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:776)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
at java.lang.Thread.run(Thread.java:748)
com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Communications link failure during rollback(). Transaction resolution unknown.

写回答

1回答

Michael_PK

2021-08-26

参考这个试试：https://blog.csdn.net/qq_35462323/article/details/106398779

Michael_PK

慕粉3700508

也参考下这个：https://stackoverflow.com/questions/32349610/mysqlnontransientconnectionexception-communications-link-failure-during-commit 我总感觉是mysql 版本哪里不对，或者是mysql的参数配置不对引起的

2021-09-01

共2条回复

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1001 学习 · 225 问题

查看课程

相似问题

如何用代码提交打包好的job到flink集群？

回答 1

Flink SQL提交

回答 1

两阶段提交

回答 1

exactly-once的实现原理是什么

回答 1

clickhouse 集群搭建失败

回答 1

打开慕课网App查看更多内容