Release-2.2.1

Release Notes

Improvements and Bug fixes

1. [docs] Update the dependencies version used in docs to 2.2.0
2. [hotfix][docs] Fix jar link for PolarDB-X docs (#1013)
3. [docs] Add example for Scan Newly Added tables feature (#1016)
4. [hotfix][docs] Fix misspell of docs title
5. [docs][mysql] Add note to make the tableList usage and dependencies clearer (#1037)
6. [docs] Update the supported sink vendors
7. [sqlserver] Add more supported(tested) SqlServer versions (#1049)
8. [oceanbase] Remove useless dependency and code of test (#1046)
9. [docs][mysql] Fix connector document link error (#1043)
10. [mysql] Serialize isSuspended flag for MySqlBinlogSplit (#1055)
11. [common] Apply filter on ResolvedSchema to keep physical columns only (#1097)
12. [docs][mongodb] Update document about MongoDB database and collection regex filter (#1090)
13. [mysql] Throw RuntimeException timely in snapshot scan phase (#1099)
14. [hotfix][tidb] Fix RowKind.INSERT judgement condition (#1104)
15. [mysql] Catch and hold exception in chunk splitter thread and rethrow in getNext() (#1110)
16. [mysql] Use the gtid set firstly when compare the binlog offset (#1111)
17. [mysql] Add heartbeatInterval field to equals() and hashCode() (#1118)

Download

• flink-sql-connector-mongodb-cdc-2.2.1.jar
• flink-sql-connector-mysql-cdc-2.2.1.jar
• flink-sql-connector-oceanbase-cdc-2.2.1.jar
• flink-sql-connector-oracle-cdc-2.2.1.jar
• flink-sql-connector-postgres-cdc-2.2.1.jar
• flink-sql-connector-sqlserver-cdc-2.2.1.jar
• flink-sql-connector-tidb-cdc-2.2.1.jar

Documentation

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