wudi
wudi
### Feature 1. Support Flink 1.15 read and write 2. Optimize log dependencies and delete log-related dependencies of pom files ### Bugfix 1. Solve the exception when MaxRetries = 0...
# Features & Improvements 1. Support flink1.19 2. Synchronous creation of tables in the entire database supports custom Bukcet #307 3. Unify DorisSink and DorisBatchSink #309 4. Add copymode writing...
# Features & Improvements 1. Automatically turn on redirection, default value policy #304 2. Add the set type of mysql 3. Add binary varbinary type to sqlserver creation table 4....
## Feature & Improvement 1. Add ITCase and E2ECase to the pipeline #275 #270 2. Code CodeFormat, refer to https://flink.apache.org/zh/how-to-contribute/code-style-and-quality-formatting/ 3. Add arrow type writing #265 4. SQLServer CDC synchronizes...
## Feature & Improvement 1. Support Doris’ Map, struct type #212 2. Optimize schema change #167 #205 3. Support direct connected be writing #187 4. Supports batch writing and does...
# Proposed changes Issue Number: close #xxx ## Problem Summary: Optimize commit judgment logic ## Checklist(Required) 1. Does it affect the original behavior: (Yes/No/I Don't know) 2. Has unit tests...
## Feature & Improvement 1. Support Flink1.17 version 2. Support Synchronize the mysql database In version 1.4.0, FlinkCDC is integrated to support MySQL's entire database synchronization. Users can use Connector...
## Feature Add JsonDebeziumSchemaSerializer for schema change with datastream #64 ## Thanks Thanks to everyone who has contributed to this release: @JNSimba
## Feature Support doris catalog #60 Add RowSerializer for datastream #71 Support 'sink.parallelism' config for flinksql #72 #77 Support flink table lookup join #61 Add JsonDebeziumSchemaSerializer for schema change with...
## Feature Support Flink 1.16 version Support doris catalog #60 Add RowSerializer for datastream #71 Support 'sink.parallelism' config for flinksql #72 #77 Support flink table lookup join #61 Add JsonDebeziumSchemaSerializer...