flink-cdc issues

[FLINK-36105] Fix unable to restore from checkpoint with Flink 1.20

This closes FLINK-36105. Some manual testing reveals that Flink CDC job could not restore from savepoint when using Flink 1.20.0. Turns out FLINK-34455 (https://github.com/apache/flink/pull/24320) has moved `RestoreMode` enum class from...

yuxiqian

build

cli

reviewed

[FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform

Currently, such transform rule could not work: ```yaml transform: projection: 'A' as result filter: tag >= 0 projection: score as result filter: tag < 0 ``` Here, `score` column will...

MOBIN-F

runtime

Add insert-only change stream option

1

Adds the option to do an insert-only stream for connectors that support specifying a changelog mode. This allows debezium connectors to be imported into flink as stream tables to take...

henneberger

docs

postgres-cdc-connector

[minor][docs] add Download Page in overview.md for Pipeline connectors.

Add download page for Pipeline connectors. Starting from 3.1.0 as the package prefix of previous release version was `com.ververica`.

lvyanquan

docs

[FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType

5

Added numRecordsOut/numRecordsOutRate metrics for each OperationType `INSERT`, `UPDATE`, `DELETE`. Removed table identifier from metrics name. With monitoring tools such as prometheus, we can distinguish flink job, db, and table using...

SML0127

docs

mysql-cdc-connector

[FLINK-36052] Add elasticsearch.md for elasticsearch pipeline connector

1

add elasticsearch.md for elasticsearch pipeline connector

proletarians

docs

[Mysql Pipline] Support mysql pipline rate limit

3

This PR Support speed rate, Prevent too much data in the initial stage from causing pressure downstream usage： ```yaml source: type: mysql .... .... sink: ... .... pipeline: name: Sync...

gaoyan1998