[
https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhang closed FLINK-37081.
-------------------------
Resolution: Later
> 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
> Assignee: zhang
> Priority: Major
> 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)
