[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750120#comment-17750120 ]
jasonliangyc commented on FLINK-32587: -------------------------------------- Hi [~jiabao.sun] , got it, I will create an issue in github cdc and my configurations are as below: flink: 1.17.0 flink-connector-jdbc-3.1.1-1.17.jar flink-sql-connector-sqlserver-cdc-2.3.0.jar mssql-jdbc-12.2.0.jre8.jar sqlserver: Microsoft SQL Server 2014 > The results returned from the CDC sql query are null or the value was changed > unexpectly > ---------------------------------------------------------------------------------------- > > Key: FLINK-32587 > URL: https://issues.apache.org/jira/browse/FLINK-32587 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client > Affects Versions: 1.17.0, 1.17.1 > Reporter: jasonliangyc > Priority: Critical > Attachments: image-2023-07-13-17-35-32-235.png, > image-2023-07-13-17-37-56-908.png, image-2023-07-21-14-48-31-572.png > > > 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. > {code:java} > 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' > ); {code} > Run the query for the first time, the data look normal. > !image-2023-07-13-17-35-32-235.png|width=535,height=141! > > 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. > !image-2023-07-21-14-48-31-572.png|width=533,height=159! -- This message was sent by Atlassian Jira (v8.20.10#820010)