Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决?

问题1:大佬,Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决呢。我的代码中没有时间转换的代码,感觉像debezium解析的问题?image.png
问题2:不是,出现了这个问题,想看看升级到2.4.1版本能不能解决的,但是升到2.4.1版本报这个错误image.png

展开
收起
真的很搞笑 2023-08-28 15:22:51 102 分享 版权
1 条回答
写回答
取消 提交回答
  • 回答1:我看你上面说的是,是版本升级从状态回复?
    回答2:包路径不一定是对的,从新启动,此回答整理自钉群“Flink CDC 社区”

    2023-08-28 15:51:53
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理