[
https://issues.apache.org/jira/browse/FLINK-40161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv reassigned FLINK-40161:
----------------------------------
Assignee: Mao Jiayi
> 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
> Assignee: 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)
