Closed mjp27258 closed 2 years ago
Caused by: org.apache.kafka.connect.errors.ConnectException: Lock wait timeout exceeded; try restarting transaction Error code: 1205; SQLSTATE: 40001.
This seems to be a flink-connector-kafka issue, you can go to flink community for help.
flink-connector-kafka
The problem has been solved. Upgrade flink-connector-mysql-cdc to 2.1.1
Caused by: org.apache.kafka.connect.errors.ConnectException: Lock wait timeout exceeded; try restarting transaction Error code: 1205; SQLSTATE: 40001.