flink cdc失败

╰半夏微凉° 2022-10-18 01:39 252阅读 0赞

[] - Step 8: rolling back transaction after abort
    2021-06-04 17:18:57,132 ERROR io.debezium.connector.mysql.SnapshotReader                   [] - Failed due to error: Aborting snapshot due to error when last running 'SELECT * FROM `hupu_du_community`.`trend`': Can't call rollback when autocommit=true
    org.apache.kafka.connect.errors.ConnectException: Can't call rollback when autocommit=true Error code: 0; SQLSTATE: 08003.
    	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:857) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1147) [?:1.8.0_102]
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622) [?:1.8.0_102]
    	at java.lang.Thread.run(Thread.java:834) [?:1.8.0_102]
    Caused by: java.sql.SQLNonTransientConnectionException: Can't call rollback when autocommit=true
    	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at com.mysql.cj.jdbc.ConnectionImpl.rollback(ConnectionImpl.java:1833) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:766) ~[ververica-connector-mysql-1.12-vvr-3.0.1-SNAPSHOT-jar-with-dependencies.jar:1.12-vvr-3.0.1-SNAPSHOT]
    	... 3 more
    2021-06-04 17:18:57,144 INFO  io.debezium.jdbc.JdbcConnection                              [] - Connection gracefully closed