jasonliangyc created FLINK-32587:
------------------------------------
Summary: 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.1, 1.17.0
Reporter: jasonliangyc
Attachments: image-2023-07-13-17-35-32-235.png,
image-2023-07-13-17-37-56-908.png
I created a CDC table 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 cdc source table don't contain these
data
!image-2023-07-13-17-37-56-908.png|width=469,height=175!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
