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

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日