flink-cdc

flink-cdc copied to clipboard

[cdc][base]Support dynamically table addition in flink-cdc-base

1

#1152 Support dynamically table addition in flink-cdc-base from the existing MySQL connector.

molsionmo

[build] Add maven wrapper

3

add maven wrapper

wuzhenhua01

[oceanBase] add metrics for oceanbase cdc connector

4

add metrics for oceanbase cdc connector #986

LXin96

[mysql] a new way to find binlog/positon in timestamp startupmode

1

reverse traverse all binlog file in database, find binlog position by compare binlog event timestamp and specified timestamp, then start read binlog from this binlog/position

lidoudou1993

[Fix a Bug] add supported for Oracle CDB mode at OracleIncrementalSource

3

it could not read the PDB tables when using OracleIncrementalSource at Oracle CDB mode,Therefore, check whether the pdb is empty when creating a connection. If it is not empty, switch...

luckes-yang

[common] Improve implementation of offset backing store

3

Simplified the offset backing store

wuzhenhua01

fix bug 'mysql primary key of binary data type is compared incorrectly'

7

mysql table use the id column of binary type as the primary key, when mysql cdc do the snapshot split. It will get min and max value of id column...

stgztsw

[DOC] When type is number,update doc

3

Oracle type | Flink SQL type -- | -- NUMBER(p, s > 0) s >= 38 or (s < 38 , p + s > 38) | STRING -- |...

wangxiaojing

Add a table of cdc json type

1

Add a table of cdc json type. Read mysql/oracle/postgres/sqlserver cdc data and output it as a json string. The effect is the same as that of the datastream api, here...

waywtdcc

Update mysql-postgres-tutorial-zh.md

1

由于debezium/example-xxx默认时区，会导致大家运行demo是会失败。

slieer