flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
add oracle pipeline connector.
Add support for Postgres partitioned table 2 test cases added: - Discover partitioned table - IT test to verify snapshot and wal events can be consumed for partitioned table
I've implemented a solution where data is collected from MySQL once and then sent to multiple target data sources, such as Paimon, Kafka, and StarRocks, which reduces redundant data collection....
https://issues.apache.org/jira/browse/FLINK-34864 Previously, in the scenario of multi-table synchronization such as from MySQL to Doris, if some tables had no primary keys, it would directly result in an error, which affected...
[FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly
detail: FLINK-37217
[FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted
[https://issues.apache.org/jira/browse/FLINK-37855](url) MySqlSchemaUtils#listTables and TableDiscoveryUtils#listTables is called to get the table names of all tables that need to be processed, However, in scenarios involving many databases and tables, this method call...
This closes FLINK-36520, FLINK-36590. Currently, trying to use MySQL CDC with MySQL 8.4 would cause the following exception: ``` Caused by: org.apache.flink.util.FlinkRuntimeException: Read split MySqlSnapshotSplit{tableId=customer.customers, splitId='customer.customers:0', splitKeyType=[`id` BIGINT NOT NULL],...
This closes FLINK-37905. As reported by @ruanhang1993, any non-ascii string literals in transform expressions will be encoded into something like `"&'\xxxx"`, which is unexpected since Unicodes are fully supported in...
Desc:[FLINK-37096](https://issues.apache.org/jira/browse/FLINK-37096)
