Skip to content

[FLINK-40161] Log original MySQL DDL events before parsing#4478

Open
haruki-830 wants to merge 1 commit into
apache:masterfrom
haruki-830:FLINK-40161
Open

[FLINK-40161] Log original MySQL DDL events before parsing#4478
haruki-830 wants to merge 1 commit into
apache:masterfrom
haruki-830:FLINK-40161

Conversation

@haruki-830

Copy link
Copy Markdown
Contributor

Summary

This commit adds logging for original MySQL DDL events before they are parsed by the Flink CDC MySQL source. When DDL parsing fails, users can now find the original DDL statement together with its binlog coordinates in the logs, making troubleshooting easier.

Key Changes

  1. Log Original MySQL DDL Events
  • Added info-level logging in MySqlStreamingChangeEventSource before calling parseStreamingDdl(...).
  • Logs the database name and original DDL SQL.
  • Logs binlog file name and event start/end positions when the event header provides them.
  1. Keep ROLLBACK Handling Separate
  • Keeps the existing dedicated warning path for ROLLBACK.
  • Avoids logging ROLLBACK as a DDL event because it is not a schema change.

JIRA Reference

https://issues.apache.org/jira/browse/FLINK-40161

@haruki-830

Copy link
Copy Markdown
Contributor Author

@lvyanquan PTAL.THANKS!

@haruki-830
haruki-830 marked this pull request as ready for review July 17, 2026 09:49

@lvyanquan lvyanquan left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants