flink-cdc

flink-cdc copied to clipboard

[cdc-composer][tests] Refactor newline handling for cross-platform compatibility

3

The hardcoded '\n' character was causing failures in unit tests on Windows platforms. Replace hardcoded newline character '\n' with 'System.lineSeparator()' to improve code portability across different operating systems.

Cqz666

[mysql] Error message more cautious

1

[mysql] Error message more cautious

baxinyu

[pipeline-connector][doris] Extract type mapping logic

2

Currently in DorisSink, the type mapping logic directly reuses the Flink Doris Connector. Although it is more convenient, it forms a strong binding relationship with the connector in terms of...

JNSimba

[mysql-cdc] Current binlog offset add serverId, fix incremental-snapshot scan data lose

3

Current binlog offset add serverId, fix incremental-snapshot scan data lose link https://github.com/ververica/flink-cdc-connectors/issues/2794

EchoLee5

[db] When modifying the time zone connection parameters in the datab…

2

…ase, the last connection information is still used (#2590) [db] When modifying the time zone connection parameters in the database, the last connection information is still used (#2590)

lizhongze1

Refactoring code.

1

Refactored some of the code.

parthcri1997

[hotfix] [base] Fix the serialization error occurring with table names containing dot

8

fix issue #2536

edmond-kk

The uniqueidentifier type in SQL Server cannot be compared using ObjectUtils.compare.

4

The uniqueidentifier type in SQL Server cannot be compared using ObjectUtils.compare. For example, in SQL Server, the value 'C6D6083A-4D2A-40D0-B20A-000005972E13' is considered less than 'B63D3AA7-8BC8-4C0F-BACD-FFFFFDAA57CD'. ```sql DECLARE @uuid1 uniqueidentifier = 'C6D6083A-4D2A-40D0-B20A-000005972E13';...

comien

[postgres] Remove unnecessary schema fresh to improve performance.

13

PR of #2570 ### Motivation It's very time-consuming for postgres to refresh schema if there are many tables to read. According to our testing, refreshing 400 tables takes 15 minutes....

lzshlzsh

[mysql] Add custom configurations for ConnectionPool which starts with `hikari.`

1

this closes https://github.com/ververica/flink-cdc-connectors/issues/2509 Add this enhancement in mysql firstly. If it's appropriate, will then add to other sources. @leonardBang @ruanhang1993 PTAL to check whether it's necessary.

lvyanquan