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