Release Notes

Improvements and Bug fixes

1. [mysql] Fix the MySqlSnapshotSplitAssigner may assign duplicate splits
2. [mysql] Fix the restoration failure when checkpoint happened in one MySQL transaction
3. [mysql] Fix the ClassCastException in RecordUtils
4. [mysql] Optimization that skips the binlog read if the low watermark equals high watermark
5. [mysql] Support wide table with huge number of columns
6. [mysql] Use min/max of split key and row count to describe the distribution of table
7. [mysql] Add source metrics for MySqlParallelSource
8. [tests] Correct the argument order of assertArrayEqualInOrder/assertArrayEqualAnyOrder
9. [tests] Introduce assertEqualsInOrder/assertEqualsInAnyOrder methods for test
10. [tests] Improve the unstable test testStartupFromLatestOffset in MySqlConnectorITCase
11. [docs] Fix the broken link in readme
12. [docs] Correct DataStream API usage in document examples
13. [docs] Support build document website locally
14. [docs] Update documentation of tutorials
15. [docs] Add meaningful title for tutorials
16. [build] Use tools with stable version in building docs
17. [build] Fix maven connection timeout issue in azure CI

Download

• flink-sql-connector-mysql-cdc-2.0.2.jar
• flink-sql-connector-postgres-cdc-2.0.2.jar
• flink-format-changelog-json-2.0.2.jar

Documentation

• https://ververica.github.io/flink-cdc-connectors