(flink-cdc) branch master updated: [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

lvyanquan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 124bffef4 [FLINK-40161][mysql] Log original MySQL DDL events before 
parsing (#4478)
124bffef4 is described below

commit 124bffef4e8ccc5845fd72b9cbecad209a7394b6
Author: haruki <jennie...@outlook.com>
AuthorDate: Sun Jul 19 10:38:59 2026 +0800

    [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478)
---
 .../mysql/MySqlStreamingChangeEventSource.java         | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
index 557a149a2..205582ca8 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
@@ -652,6 +652,24 @@ public class MySqlStreamingChangeEventSource
             LOGGER.warn(
                     "Rollback statements cannot be handled without binlog 
buffering, the connector will fail. Please check '{}' to see how to enable 
buffering",
                     MySqlConnectorConfig.BUFFER_SIZE_FOR_BINLOG_READER.name());
+        } else {
+            // ROLLBACK is not a DDL event and already has a dedicated warning 
above.
+            EventHeader header = event.getHeader();
+            if (header instanceof EventHeaderV4) {
+                EventHeaderV4 eventHeader = (EventHeaderV4) header;
+                LOGGER.info(
+                        "Received MySQL DDL event at {} [{}-{}], database={}, 
ddl={}",
+                        offsetContext.getSource().binlogFilename(),
+                        eventHeader.getPosition(),
+                        eventHeader.getNextPosition(),
+                        command.getDatabase(),
+                        sql);
+            } else {
+                LOGGER.info(
+                        "Received MySQL DDL event, database={}, ddl={}",
+                        command.getDatabase(),
+                        sql);
+            }
         }
 
         final List<SchemaChangeEvent> schemaChangeEvents =