Flinkcdc读取Oracle的时候,报错,是什么原因?

Flinkcdc读取Oracle的时候,报错,是什么原因?570f621051f819dd33857644e5bc885d.png
这块我的flink版本是1.13,但是我需要flinkcdc版本是2.4,所以flinkcdc的版本暂时无法修改,只能够变动flink的版本。

展开
收起
十一0204 2023-07-19 16:46:51 256 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    可以看出是 Java 类加载器无法找到所需的类,在这种情况下,可能是由于以下原因导致的:

    Flink 版本不兼容:如果您正在使用的 Flink 版本与所使用的 Oracle 数据库版本不兼容,可能会导致 Flink CDC 无法读取或写入数据。建议您检查您所使用的 Flink 版本和 Oracle 数据库版本,并根据实际情况进行调整和优化。

    Oracle 驱动问题:如果您所使用的 Oracle 驱动程序版本与 Flink CDC 不兼容,可能会导致 Flink CDC 无法读取或写入数据。建议您检查您所使用的 Oracle 驱动程序版本,并确保与 Flink CDC 兼容。

    类路径配置问题:如果您的类路径没有正确配置或者相关类文件未正确加载,可能会导致 Java 类加载器无法找到所需的类。建议您检查您的类路径配置,并确保相关类文件已正确加载。

    网络连接问题:如果您的网络环境存在问题,可能会导致 Flink CDC 无法连接到 Oracle 数据库或读取数据。建议您检查您的网络连接,并确保网络环境正常。

    2023-07-29 21:07:51
    赞同 展开评论
  • 意中人就是我呀!

    "是不是缺少

    org.apache.flink:flink-shaded-guava
    这个依赖或者这应该是flink和cdc的版本不匹配。此回答整理至钉群“Flink CDC 社区”。"

    2023-07-19 17:30:59
    赞同 展开评论

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

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