flink-cdc

flink-cdc copied to clipboard

[fix][cdc-connector][mysql] Fix NoClassDefFoundError when create new table in mysql cdc source

5

### Prepare a Pull Request Fixes: #3035 ### Motivation When we package maven jar for flink-cdc-connector-mysql-cdc module, the flink-cdc-common moduel is excluded. So we can use org.apache.commons.lang3.StringUtils instead of com.ververica.cdc.common.utils.StringUtils...

pengmide

### 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.1 ### Database and its version source:...

pengmide

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation I hope to develop the source and sink connectors of the pipeline, but...

cobolbaby

### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation If I want to extend the implementation of end-to-end data synchronization, such as...

cobolbaby

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

caohb1985

[cdc-connector][mysql][hotfix] Avoid mysql source to read data after high_watermark in backfill phase

1

### Reason Current, we emit record first then determine whether is after out of bound. So it may emit data after high_watermark. ### Minimal reproduce step ```java @Test public void...

loserwang1024

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

leoooo-ma

### 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.0 ### Database and its version starrocks...

kongkongstar

[cdc-connector][db2] Db2 support incremental source

8

### Prepare a Pull Request - Fixes #2869 ### Motivation Db2 support incremental source ### Modifications * Add db2 incremental source code * Add doc * Add ITcase UT and...

gong

[oracle-cdc]Optimized slow oracle real-time synchronization

4

#https://github.com/ververica/flink-cdc-connectors/issues/1999 To solve the problem of slow real-time oracle synchronization, add a table name as a query condition, improving query efficiency and reducing memory usage

weAreFriendYo