Flink CDC Issue Import created FLINK-34812: ----------------------------------------------
Summary: [Bug] During the snapshot phase, projection is not being performed according to the user defined schema. Key: FLINK-34812 URL: https://issues.apache.org/jira/browse/FLINK-34812 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Flink CDC Issue Import ### Search before asking - [X] I searched in the [issues|https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.17.0 ### Flink CDC version <=master ### Database and its version such as mysql,oracle,pg,sqlserver,take oracle 11g as an example. ### Minimal reproduce step Assuming the ABC table contains three fields, A, B, and C. **ddl:** CREATE TABLE ABC (  A BIGINT NOT NULL,  B STRING,  PRIMARY KEY(A) NOT ENFORCED ) WITH (  'connector' = 'oracle-cdc',  'hostname' = '192.168.xxx.xxx',  'port' = '1521',  'username' = 'xxx',  'password' = 'xxx',  'database-name' = 'xxx',  'schema-name' = 'xxx',  'table-name' = 'ABC',  'debezium.log.mining.strategy' = 'online_catalog',  'debezium.log.mining.continuous.mine' = 'true',  'debezium.database.tablename.case.insensitive' = 'false']; **dml:** select * from ABC; ### What did you expect to see? **should be:** ![查部分|https://github.com/ververica/flink-cdc-connectors/assets/57552918/b8a302e8-63dd-42ca-b2f2-67e4bd356bfa] Projection is performed according to the schema definition, and it takes 2.534 seconds. ### What did you see instead? **snapshot phase:** ![查全部|https://github.com/ververica/flink-cdc-connectors/assets/57552918/6504278f-4a00-43ba-8818-558a732c3f82] The screenshot indicates that an `*` was used as the query condition, and projection was not performed as defined by the schema. And it took 3.532 seconds to execute this query. ### Anything else? When dealing with a large amount of data and numerous partitions, this time can become quite significant. ### Are you willing to submit a PR? - [X] I'm willing to submit a PR! ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/2470 Created by: [hzjhjjyy|https://github.com/hzjhjjyy] Labels: bug, Created at: Fri Sep 08 09:43:07 CST 2023 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)