flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
This resolves a problem encountered in our production environment when there are too many tables to be read on the snapshot phase and each takes quite a lot of time...
…to be capture. fiexs: #1184
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) ~[?:?] ```
Users need console sink to make simple attempts, add documents for console(values) pipeline connector.
This adds a simple DeserializationConverterFactory for PostgisGeometry objects, like it is done in with the com.ververica.cdc.connectors.mysql.table.MySqlDeserializationConverterFactory. But in the case of PostGIS the data is encoded in ewkb, which should...
This contribution is about allowing transaction metadata events to flow in the output.
When we enter binlog phase in a cdc job, the SplitAssigner only assigns a binlog split to one of the SourceReaders, namely the first reader waiting for splits in the...
修复 mysql-cdc 因为大小写敏感导致 非自增型主键 chunks 分配大小不均匀问题。 修复逻辑： 1、mysqlcdc 非自增型主键方法均会走splitUnevenlySizedChunks 方法。 2、在splitUnevenlySizedChunks方法中在chunks之前判断主键collation 是否大小写敏感 3、mysql中字段类型 collation 为null 以及是以_ci 结尾的都是大小写不敏感的 4、如果主键大小写敏感，则走原逻辑。如果主键大小写不敏感则统一将字符转换为小写字符串 再进行ObjectUtils.compare比较
