使用 flink-connector-mysql-cdc 監聽二進制格式主鍵的 mysql 時出現異常處理

在使用 flink-connector-mysql-cdc 2.1.1 監聽 mysql 時，如果 mysql 表的主鍵是二進制格式，可能會出現以下錯誤：

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

該異常是由拆分表時出現 classcastexception 所致。

解決方案：

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