[
https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750126#comment-17750126
]
Jiabao Sun commented on FLINK-32587:
------------------------------------
Thanks [~jasonliangyc] .
There's a known issue that old version's sqlserver cdc connector will subscribe
the same table of different database and that problem was fixed by the 2.4.1
version. But the problem of unexpected data from same table is never reported
before.
You can check whether the table of same name exists in different databases and
try to use the latest version of the connector to see if this problem still
exists.
> 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)
