flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
[mysql] expose meta_ts field in the metadata through flink sql #1141
[oracle]Use Incremental Snapshot Framework for Oracle CDC Connector #1079 @leonardBang 1. flink-connector-oracle-cdc incremental Snapshot implemention base on flink-cdc-base 2. It lacks tests, and then replenishes the corresponding test classes and...
**Is your feature request related to a problem? Please describe.** cdc-base module lack tests so that many fixs for cdc-base is diffcult to implement. **Describe the solution you'd like** we...
**Is your feature request related to a problem? Please describe.** Some business scenes want to capture change events, which you have configed specific op types(`delete`,`update`,`insert`). **Describe the solution you'd like**...
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.0 - Database and...
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.0 - Database and...
In mysql use utf8_general_ci will case，eaxmple : 'a' = ‘A' , use utf8_bin will sort by asscii ,example: 'A' < 'a'. But will sort by asscii in java. Use binary...
Through the DataStream Source to listen to a table, use JsonDebeziumDeserializationSchema Field name order_id, type bigint(20) mysql order_id = 1518478400438665216 Flink order_id = "FRKx5vqAAAA =" Other values of the same...
[mysql]Fix jdbc connections not be closed when job was cancelled (#1347)
#1074 When creating normalizedSplitRecords in RecordUtils, original order of records are lost because the use of HashMap. Since the order might be useful in some occasion, it's better to replace...
