问题1:Flink CDC中mysql添加这种字段,cdc会报错,Invalid Java object for schema type INT64,哪位大佬知道咋解决啊? 源码这个地方的问题 问题2:还没到重写的deserialize的方法就已经爆这个错了 现在生产用的2.2,我升级成2.3,恢复任务用2.2的ck会报错,所以又会滚到2.2了
回答1:序列化的时候把转成字符串 回答2:应该不会吧,那你看看是不是jar包版本或者数据库驱动的问题 mysql mysql-connector-java 8.0.33 要不升级版本试试,我用的flinkcdc2.3.0,序列化的时候这样转一下 2.3 有bug ,我也在尝试回滚到2.2 https://github.com/ververica/flink-cdc-connectors/pull/2063,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。