yoheimuta opened a new pull request, #3876: URL: https://github.com/apache/flink-cdc/pull/3876
This closes [FLINK-36945](https://issues.apache.org/jira/browse/FLINK-36945). [The Vitess schema migration tool](https://vitess.io/docs/user-guides/schema-changes/ddl-strategies/) renames multiple tables within a single statement to perform schema changes, which are not correctly recognized by MySQL CDC. The issue arises because the schema change event emitted by Debezium includes multiple table IDs, which MySQL CDC does not expect. As a result, changes for tables specified in the table filter configuration may be unintentionally filtered out. This can prevent schema changes from being saved in the state, which is critical for recovering the job from a snapshot. This PR updates the source info with the correct table name to align with MySQL CDC expectations, ensuring schema changes are saved correctly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
