[FLINK-37837][core] Always add create.table to include.schema.changes option#4262
[FLINK-37837][core] Always add create.table to include.schema.changes option#4262Hisoka-X wants to merge 1 commit intoapache:masterfrom
Conversation
|
Thank you for your contribution and i left some comment |
|
I think that |
Users can set create.table into exclude.schema.changes. |
|
and i think the jira's error was
I think this is the correct processing logic, if users always create tables first, and creating tables may be a failure that leads to task failure. |
This close https://issues.apache.org/jira/browse/FLINK-37837
This pull request ensures that the
CreateTableEventis always included in the set of schema change events unless the user explicitly excludes it. This change guarantees the foundational event is present for proper schema evolution handling.