apache
[MySql] not to throw an exception when bin log format changed from row to others to stop job from endless restarting.
issue:
flink job get restarted and stuck at an exception when bin log format changed from row to others
exception : Caused by: io.debezium.DebeziumException: Received DML
versions: flink 1.13 cdc 2.2.1 mysql 5.6
suggested solution: not to throw an exception when bin log format changed from row to others and increase the bin log offset by one until the bin log format changes back to row
Debezium has a issue to fix this DBZ-3949. We could set event.deserialization.failure.handling.mode to warn to skip this failure.
Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!
