使用 flink-connector-mysql-cdc 監(jiān)聽二進(jìn)制格式主鍵的 mysql 時(shí)出現(xiàn)異常處理

在使用 flink-connector-mysql-cdc 2.1.1 監(jiān)聽 mysql 時(shí)，如果 mysql 表的主鍵是二進(jìn)制格式，可能會(huì)出現(xiàn)以下錯(cuò)誤：

org.apache.flink.util.FlinkRuntimeException: **Generate Splits for table 。。。 error** Caused by: java.lang.ClassCastException: **[B cannot be cast to java.lang.Comparable**

該異常是由拆分表時(shí)出現(xiàn) classcastexception 所致。

解決方案：

• 升級(jí)版本：更新到 flink-connector-mysql-cdc 的最新版本（例如 2.1.2），該版本修復(fù)了此問題。
• 提交 issues：在 github 上提交 issues，可以參考 ververica 官方提供的鏈接：https://github.com/ververica/flink-cdc-connectors/issues/2746