flink-cdc

flink-cdc copied to clipboard

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation To be supplemented. ### Solution To be supplemented. ### Alternatives None. ### Anything...

aiwenmo

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation To be supplemented. ### Solution To be supplemented. ### Alternatives None. ### Anything...

aiwenmo

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation To be supplemented. ### Solution To be supplemented. ### Alternatives None. ### Anything...

aiwenmo

[Feature-2932][Pipeline] Flink CDC pipeline supports transform

7

This is a draft pull request, and the functionality has not been completed yet. Please discuss the details, implementation, and optimization under this PR. I will complete the remaining code....

aiwenmo

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. flink-cdc-connector版本：3.0.1 ### Motivation 实时感知当前任务正在拉取的表 ### Solution 可在MySqlPipelineRecordEmitter的构造函数中，通过入参sourceReaderMetrics和sourceConfig向指标中汇报拉取表列表 ### Alternatives _No response_ ### Anything else? _No...

BaoPiao

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation 有一个很常见的场景，在一些政府部门（医保数据上报）。市向省、省向国家层层上报数据，需要保留删除和修改数据，防止下一级删除数据。在目标表有一个标记字段，记录是删除，更新和插入。 ### Solution _No response_ ### Alternatives _No response_ ### Anything else? _No...

melin

[Bug] 3.0 StarRocksDataSink不支持 flink1.14 【java.lang.NoClassDefFoundError: org/apache/flink/api/connector/sink2/Sink】

1

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.14.6 ### Flink CDC version 3.0.0 ### Database and its version starrocks...

cleverUtd

[enhancement] add param which contain column comments of source table field

7

add param which contain column comments of source table field. fix #3007

dufeng1010

Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug]

8

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.18 ### Flink CDC version 3.0 ### Database and its version Starrocks...

biyinggun

[Bug] Mysql is synchronized to doris, and an error is reported when adding or deleting data after dropping column.

2

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.18.1 ### Flink CDC version 3.0.0 ### Database and its version mysql...

didiaode18