[jira] [Assigned] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

["Leonard Xu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Leonard Xu reassigned FLINK-37081:
----------------------------------

    Assignee: zhang

> 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)