[jira] [Created] (FLINK-34812) [Bug] During the snapshot phase, projection is not being performed according to the user defined schema.

[Flink CDC Issue Import (Jira)]

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 (
     &emsp;A BIGINT NOT NULL,
     &emsp;B STRING,
     &emsp;PRIMARY KEY(A) NOT ENFORCED
     ) WITH (
     &emsp;'connector' = 'oracle-cdc',
     &emsp;'hostname' = '192.168.xxx.xxx',
     &emsp;'port' = '1521',
     &emsp;'username' = 'xxx',
     &emsp;'password' = 'xxx',
     &emsp;'database-name' = 'xxx',
     &emsp;'schema-name' = 'xxx',
     &emsp;'table-name' = 'ABC',
     &emsp;'debezium.log.mining.strategy' = 'online_catalog',
     &emsp;'debezium.log.mining.continuous.mine' = 'true',
     &emsp;'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)