flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

Flink CDC is a streaming data integration tool

Results 606 flink-cdc issues
Sort by recently updated
recently updated
newest added

Firstly, support oracle, postgres and sqlserver

修复oracle数据库表主键是NUMBER类型且不指定p,s长度时报校验异常:org.apache.flink.table.api.ValidationException: Decimal precision must be between 1 and 38 (both inclusive).

修复oracle数据库scan.incremental.snapshot.chunk.key-column设置不生效的问题

Modify the schema and table name snapshot data reading problem with the same name. For example: I want to get data from databaseName: test1 schemaName: dbo tableName: fl_test, but my...

DBZ-5589 Mysql connector can't handle the case sensitive of rename/change column statement The bug is only fixed in debezium2.0 version, and I have copied a copy of the solution.

Add a AbstractJdbcSourceChunkSplitter to handle common logic

This change is w.r.t to the corresponding changes done to mysql binlog connector and Debezium to support transaction payload events (generated when mysql server has binlog compression ON). Ticket in...