zhang created FLINK-37081:
-----------------------------
Summary: The debezium version of sqlserver cdc needs to be
upgraded to 2.6 or higher
Key: FLINK-37081
URL: https://issues.apache.org/jira/browse/FLINK-37081
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Environment: Microsoft SQL Server 2016 (SP1-CU15)
Reporter: zhang
Attachments: image-2025-01-09-14-34-32-514.png
The sql to get cdc data before debezium version 2.6 was
{code:java}
SELECT *# FROM [#db].cdc.[fn_cdc_get_all_changes_#](?, ?, N'all update old')
order by [__$start_lsn] ASC, [__$seqval] ASC, [__$operation] ASC {code}
The “order by [__$start_lsn] ASC, [__$seqval] ASC, [__$operation] ASC” part of
the ordering is not necessary, and the results of “fn_cdc_get_all_changes” will
be sorted by “__$start_lsn, __$ command_id, __$seqval, __$operation” by
default.
If the cdc table has a large amount of data, this extra sorting can cause
serious performance problems.
This redundant sorting has been removed in debezium version 2.6 and above
!image-2025-01-09-14-34-32-514.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
