欢迎您访问新疆栾骏商贸有限公司,公司主营电子五金轴承产品批发业务!
全国咨询热线: 400-8878-609

新闻资讯

技术学院

使用 Flink-Connector-MySQL-CDC 监听二进制主键的 MySQL 表时出现异常该如何处理?

作者:碧海醫心2024-11-09 00:00:00

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