flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard
verified publisher icon apache

[MySQL] Fix for DBZ-7037 and 2217 to not clear tableMapEventByTableId for fake Rotates Event

Open shikai93 opened this issue 1 year ago • 0 comments

Event log
Caused by: com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException would occur as explained in issue #2217 whereby client is restarted during the consumption process, leading to a Rotate Event that clears the tableMapEventByTableId.

This has been fixed in DBZ discussing the same issue. This PR tries to port that fix over since Flink CDC clones the MySqlStreamingChangeEventSource.

shikai93 avatar Feb 13 '24 04:02 shikai93