全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flink1.20 cdc中同步任务的时候出现ClassNotFoundException: org.apache.flink.cdc.debezium.DebeziumDeserialization

提问者：帅平问题分类：大数据

Flink1.20 cdc中同步任务的时候报错了，提示：

Caused by: java.lang.ClassNotFoundException: org.apache.flink.cdc.debezium.DebeziumDeserializationSchema
        at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:445)
        at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:587)
        at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67)
        at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65)
        at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51)
        at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
        ... 16 more

我已经引入了flink-sql-connector-mysql-cdc-3.0.1.jar，一直执行不成功，这个类在哪个包啊？

Flink

发布于：4个月前 (12-18) IP属地：四川省

3 个回答

我心已凉

你看下是否是引入的这个包

<!-- https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-mysql-cdc -->
<dependency>
    <groupId>com.ververica</groupId>
    <artifactId>flink-sql-connector-mysql-cdc</artifactId>
    <version>3.0.1</version>
    <scope>provided</scope>
</dependency>

这个包过时了，现在需要引入：

<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-mysql-cdc -->
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-sql-connector-mysql-cdc</artifactId>
    <version>3.2.1</version>
    <scope>provided</scope>
</dependency>

这个包，两个包的groupid是不一样的，换这个新的即可。

发布于：4个月前 (12-18) IP属地：四川省

我来回答