[
https://issues.apache.org/jira/browse/FLINK-40161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-40161.
--------------------------------
Fix Version/s: cdc-3.7.0
Resolution: Fixed
Merged in master via 124bffef4e8ccc5845fd72b9cbecad209a7394b6.
> Log original MySQL DDL events before parsing
> --------------------------------------------
>
> Key: FLINK-40161
> URL: https://issues.apache.org/jira/browse/FLINK-40161
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Reporter: Mao Jiayi
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.7.0
>
>
> When the MySQL CDC source handles DDL events from the binlog, it parses the
> DDL statement in *MySqlStreamingChangeEventSource#handleQueryEvent*.
> If DDL parsing fails, the current logs do not clearly show the original DDL
> statement together with the corresponding binlog position. This makes
> troubleshooting difficult, especially when users need to locate the
> problematic event from MySQL binlogs.
> We should log the original MySQL DDL event before parsing it, including the
> database name, original DDL SQL, and binlog coordinates when available.
> ROLLBACK should not be logged as a DDL event because it is not a schema
> change and already has a dedicated warning path.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
