JNSimba opened a new pull request, #3767: URL: https://github.com/apache/flink-cdc/pull/3767
**Background** In some scenarios, MySQL synchronization only expects to synchronize specified fields instead of all fields in the table. 1. The user only has the permission for some fields in MySQL 2. The user has too many fields in a single table and only wants to synchronize some fields, for example, here https://github.com/apache/flink-cdc/discussions/3058 **Current situation** For the incremental stage, you only need to configure the column.include.list property of debezium to support the synchronization of some fields in the incremental stage, refer to: https://debezium.io/documentation/reference/1.9/connectors/mysql.html#mysql-property-column-include-list For the full snapshot stage, * is currently used in MySqlSnapshotSplitReadTask, refer to ``` ``` if (isScanningData) { return buildSelectWithRowLimits( tableId, limitSize, "*", Optional.ofNullable(condition), Optional.empty()); **Solution** The user configures column.include.list, and then captures the specific columns in MySqlSnapshotSplitReadTask, and splices them when constructing Scan SQL. -- 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
