Hongshun Wang

[Bug][cdc-connectors][cdc-base] Transaction log of high_watermark read twice

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 ## Flink CDC version 3.0 ## Database and its version anyway...

[FLINK-35071][cdc-connector][cdc-base] Shade guava31 to avoid dependency conflict with flink below 1.18

4

As shown in https://github.com/ververica/flink-cdc-connectors/issues/3071, Unlike flink-table-common、flink-connector-base 、flink-core whose maven scope is provided , flink-shaded-guava and flink-shaded-force-shading will be included in the final jar package, so maybe cause dependency conflict. Now...

[docs] Add 'scan.incremental.snapshot.backfill.skip' to docs.

10

Add 'scan.incremental.snapshot.backfill.skip' to docs of mysql、postgres、oracle、mongodb、sqlserver

[Bug][mysql] Remove all previous table and add new added table will throw Exception.

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.18 ### Flink CDC version 3.0.1 ### Database and its version anyone...

[cdc-connector][mysql][hotfix] Fix NullPointerException when currentReader is null.

2

In current com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader#pollSplitRecords, if currentReader == null(for example, there is no split), NullPointerException will be thrown here: ```java private MySqlRecords pollSplitRecords() throws InterruptedException { Iterator dataIt; if (currentReader == null)...

[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...

[Bug][sqlserver] SqlServer incremental source cannot support exactly-once

4

## 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 ## Reason ### overview At first,...

DatabaseMetaData#getTables not return tables of specified database name but connected database

5

Although java.sql.DatabaseMetaData#getTables provided a param(catalog), but this function will never use it. If a database instance contains many databases, including databases A and B. Now i open a JDBCConnection to...

Sql Source is no longer compatible.

1

In current modification, option is changed from `org.apache.rocketmq.flink.common.RocketMQOptions` to `org.apache.flink.connector.rocketmq.source.RocketMQSourceOptions.` However, each key's name has been add a prefix of rocketmq.source. It means that same sql ddl will throw exception...

[FLINK-35234][hotfix][cdc-common] Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

1

Fix exception like this: ```java Caused by: java.lang.NullPointerException at org.apache.flink.cdc.common.configuration.ConfigurationUtils.convertToString(ConfigurationUtils.java:133) ~[?:?] at org.apache.flink.cdc.common.configuration.Configuration.toMap(Configuration.java:138) ~[?:?] ```