flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Motivation implify use and avoid create table ddl ### Solution _No response_ ### Alternatives...
As titled. Close #2984 .
this closes https://github.com/ververica/flink-cdc-connectors/issues/2520 Try to support notification about the status of connector, since it may be a common demand from community. However, I met some problem when add a preliminary...
In our usage scenario, the source schema of mysql and the target schema of starrocks are often different, but the table names and column names are consistent, and this pr...
### 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.3 ### Flink CDC version 3.0.0 ### Database and its version 5.7.25-TiDB-v5.2.2...
This closes https://github.com/ververica/flink-cdc-connectors/issues/2936.
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)...
Refer to #2854 Add 'flink-config' for pipeline yaml, which will overwrite the config from 'flink-conf.yaml'. cc @lvyanquan @PatrickRen
### Search before asking - [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.15.3 ### Flink CDC version 2.4.0 ### Database and its version oracle...
## Prepare a Pull Request Fixes: #2977 ## Motivation oracle cdc support server-time-zone option in table api. Modifications * Modify OracleTableSource, added serverTimeZone argument in constructor and set this argument...
