[FLINK-32587] The results returned from the CDC sql query are null or the value was changed unexpectly

• Type: Bug
• Status: Reopened
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 1.17.0, 1.17.1
• Component/s: Table SQL / Client
• Assignee: Unassigned
• Reporter: jasonliangyc
• Created: 13/Jul/23 09:42
• Updated: 02/Aug/23 09:28

Description

I created a CDC table(the sqlserver source table has more than 100 columns) as below and then run the query 'select * from so_cdc' through sql-client, it gives me the unexpected results.

CREATE TABLE so_cdc (
   REC_ID STRING,
   Create_Date TIMESTAMP(3),
   PRIMARY KEY (REC_ID) NOT ENFORCED
 ) WITH (
    'connector' = 'sqlserver-cdc',
    'hostname' = 'xxxx',
    'port' = 'xxxx',
    'username' = 'xxx',
    'password' = 'xxxx',
    'database-name' = 'xxxx',
    'schema-name' = 'xxxx',
    'table-name' = 'xxx',
    'scan.startup.mode' = 'latest-offset'
 ); 

Run the query for the first time, the data look normal.

 

But after i run the same query multiple times, it gives me the unexpected data, and i'm sure that these two columns of my sqlserver source table don't contain these data.

And i found that the values of 'REC_ID' were actually the values of another column in the sqlserver source table, it seems the query returned the wrong columns.

Above sqlserver source table is in the production database and i can't reproduce the same issue in dev db.