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

• 大数据

在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官网为

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://www.net2asp.com/3b529472a4.html

赞 (0)
« 上一篇 1天前
下一篇 » 1天前

相关推荐