当前位置:
首页 >
行业知识 >
【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官网为
上一篇:性价比固态硬盘主机