开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC一样的报错哈,这错误看起确实像序列化问题?

Flink CDC一样的报错哈,这错误看起确实像序列化问题:Caused by: java.io.InvalidClassException: org.apache.flink.streaming.connectors.kafka.table.DynamicKafkaRecordSerializationSchema; local class incompatible: stream classdesc serialVersionUID = 7316128795914937937, local class serialVersionUID = 2479642893364766617
at java.io.ObjectStreamClass.initNonProxy(Unknown Source) ~[?:?]
at java.io.ObjectInputStream.readNonProxyDesc(Unknown Source) ~[?:?]image.png
换成flink-sql-connector-kafka-1.16.2.jar后作业可执行正常,看来就是connector版本问题

展开
收起
真的很搞笑 2023-09-07 10:21:17 203 0
1 条回答
写回答
取消 提交回答
  • 根据您提供的错误信息,确实是序列化问题导致的。该错误表明您使用的 Flink 版本与 Flink 的 Kafka Connector 版本不兼容。

    具体来说,您使用的 Kafka Connector 版本为 1.16.2,但 Flink 的核心版本为 1.16.2,这两个版本之间的兼容性可能存在问题。

    解决此问题的方法是确保使用的 Flink 版本与 Kafka Connector 版本兼容。您可以尝试以下方法:

    使用与 Flink 1.16.2 版本兼容的 Kafka Connector 版本。您可以查阅 Flink 官方文档或发布说明,找到与 Flink 1.16.2 兼容的 Kafka Connector 版本,并将其用于您的项目。

    更新 Flink 版本到与 Kafka Connector 1.16.2 兼容的版本。根据您的需求,可以尝试将 Flink 更新到与 Kafka Connector 1.16.2 兼容的版本,以确保版本匹配。

    请注意,Flink 的版本兼容性是一个重要的考虑因素,确保使用相互兼容的版本组合可以减少潜在的兼容性问题。

    如果您需要进一步的帮助,请提供更多的信息,例如您使用的 Flink 和 Kafka Connector 版本,以及相关的代码和配置。这将有助于更准确地诊断和解决问题。

    2023-09-20 17:45:09
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载