Mao Jiayi created FLINK-40161:
---------------------------------
Summary: 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
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)
