Hello! 欢迎来到小浪资源网!


Flink MySQL CDC监听二进制主键报错:如何解决?


Flink MySQL CDC监听二进制主键报错:如何解决?

flink mysql cdc 监听主键为二进制格式时报错

使用 flink mysql cdc 2.1.1 监听 mysql 表时,如果表的主键是二进制格式,可能会遇到以下错误:

[b cannot be cast to java.lang.comparable

原因:

拆表时遇到问题,导致无法将二进制主键转换为可比较的类型。

解决方案:

按照问题答案中的建议,在 github 上提交了问题并得到了解决。

升级到新版本:

https://github.com/ververica/flink-cdc-connectors/issues/2746

新版本中已修复了此问题,可以正常处理二进制主键。

相关阅读