小工具知识网

当前位置: 首页 > 行业知识 > 【Flink】 ClassNotFoundException: com.ververica.cdc.debezium.utils.ResolvedSchemaUtils

行业知识

【Flink】 ClassNotFoundException: com.ververica.cdc.debezium.utils.ResolvedSchemaUtils

2026-10-21 14:57:09 来源:互联网转载

在FlinkSQL客���端中执行FlinkCDC,使用mysql连接的时候,报如下问题(Flink版本1.13.6):

()

Flink SQL> CREATE TABLE demok (
>      id int,
>      name STRING
>      ) WITH (
>      'connector' = 'mysql-cdc',
>      'hostname' = 'localhost',
>      'port' = '3306',
>      'username' = 'root',
>      'password' = 'root',
>      'database-name' = 'cdc',
>      'table-name' = 'cdc_test');
[INFO] Execute statement succeed.

Flink SQL> select * from demok;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: com.ververica.cdc.debezium.utils.ResolvedSchemaUtils

()

问题原因:引用了错误的lib包导致 ,FlinkCDC官网为

上一篇:性价比固态硬盘主机

下一篇:赭石读音揭秘,一篇文章让你彻底掌握!