开心比较堵 2024-09-18 15:02 采纳率: 73.2%
浏览 3
已结题

Flink和Flink CDC报错flink-shaded-guava

我在使用 Flink CDC 迁移数据到 Oracle 和 SQL Server 时,使用的 Flink 版本是 1.16.0,使用的 Flink cdc 版本是 3.2.0。然后 flink-shaded-guava 使用的是 31.1-jre-17.0,报错 org.apache.flink.shaded.guava30.com.google.common.collect.Lists。但是当我使用 30.1.1-jre-15.0 时,报错 org.apache.flink.shaded.guava31.com.google.common.util.concurrent.ThreadFactoryBuilder。具体信息如下:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-shaded-guava</artifactId>
    <version>30.1.1-jre-15.0</version>
</dependency>

Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava31.com.google.common.util.concurrent.ThreadFactoryBuilder
    at java.net.URLClassLoader.findClass(URLClassLoader.java:387)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:419)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:352)
    ... 13 more

当我按照提示使用31.1-jre-17.0版本时,再次出现错误。

Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava30.com.google.common.collect.Lists
    at java.net.URLClassLoader.findClass(URLClassLoader.java:387)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:419)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:352)
    ... 20 more


  • 写回答

1条回答 默认 最新

  • 开心比较堵 2024-09-18 15:27
    关注

    将Flink版本升到1.18.0
    Flink CDC使用3.2.0
    flink-shaded-guava使用31.1-jre-17.0

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 9月26日
  • 已采纳回答 9月18日
  • 创建了问题 9月18日

悬赏问题

  • ¥15 如何在vue.config.js中读取到public文件夹下window.APP_CONFIG.API_BASE_URL的值
  • ¥50 浦育平台scratch图形化编程
  • ¥20 求这个的原理图 只要原理图
  • ¥15 vue2项目中,如何配置环境,可以在打完包之后修改请求的服务器地址
  • ¥20 微信的店铺小程序如何修改背景图
  • ¥15 UE5.1局部变量对蓝图不可见
  • ¥15 一共有五道问题关于整数幂的运算还有房间号码 还有网络密码的解答?(语言-python)
  • ¥20 sentry如何捕获上传Android ndk 崩溃
  • ¥15 在做logistic回归模型限制性立方条图时候,不能出完整图的困难
  • ¥15 G0系列单片机HAL库中景园gc9307液晶驱动芯片无法使用硬件SPI+DMA驱动,如何解决?