使用 Flink-Connector-MySQL-CDC 監聽二進制主鍵的 MySQL 表時出現異常該如何處理?

使用 Flink-Connector-MySQL-CDC 監聽二進制主鍵的 MySQL 表時出現異常該如何處理?

使用 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

? 版權聲明
THE END
喜歡就支持一下吧
點贊11 分享