使用 flink connector mysql cdc 监听 mysql 时主键为二进制格式产生的异常
在使用 flink connector mysql cdc 2.1.1 监听 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。
根据 github 上的 issue (#2746),可以使用最新版本的 flink connector mysql cdc 来解决此问题。
以上就是Flink CDC Connector 监听MySQL二进制主键时报错:如何解决ClassCastException?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号