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
新版本中已修复了此问题,可以正常处理二进制主键。