flink-cdc

flink-cdc copied to clipboard

melin

[FLINK-35244][cdc-connector][tidb] Move package for flink-connector-tidb-cdc test

1

see https://issues.apache.org/jira/browse/FLINK-35244 test case for flink-connector-tidb-cdc should under `org.apache.flink.cdc.connectors.tidb` package instead of `org.apache.flink.cdc.connectors`

xieyi888

Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict.

3

Fix #2753 .

HappyHacker123

[FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization

2

Resolve [FLINK-35119](https://issues.apache.org/jira/browse/FLINK-35119). The `before` and `after` of DataChangeEvent participate in serialization in case of null value.

zhongqishang

Fix during the snapshot phase, projection is not being performed according to the user defined schema.

2

### Purpose Linked issue: close #2470 This is part 1, fixing the oracle module. If everything is okay, I'll proceed to submit pr for other modules, such as mysql, pg,...

hzjhjjyy

[FLINK-35072][cdc][doris] Support applying compatible `AlterColumnTypeEvent` to Doris sink

2

According to [Doris documentation](https://doris.apache.org/docs/sql-manual/sql-reference/Data-Definition-Statements/Alter/ALTER-TABLE-COLUMN/), altering column types dynamically is supported (via `ALTER TABLE ... MODIFY COLUMN` statement) when lossless conversion is available. However, now Doris pipeline connector has no support...

yuxiqian

[tidb] Add metrics for tidb connector

2

add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag, sourceIdleTime for TiKVRichParallelSourceFunction issue: https://github.com/ververica/flink-cdc-connectors/issues/985

xieyi888

[mongodb] Add lookup option to IncrementalSource for mongodb

5

vanliu-tx

[fix-issue-2676] repair a snapshot-split bug:

6

when use splitOneUnevenlySizedChunk, sometimes(for example, a database or a table or a column use 'utf8mb4_general_ci') we will get a big chunk. For example when the value of primaryKey like ['0000','1111','2222','3333','4444','aaaa','bbbb','cccc','ZZZZ',...]...

AidenPerce

[FLINK-35313][mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records …

9

This PR implements [#1898](https://github.com/ververica/flink-cdc-connectors/issues/1898) and exposing support in configuration just for mysql module.

yeezychao