【Flink】ValidationException: Could not find any factory for identifier ‘jdbc‘ that implements ‘org.ap

• 大数据

在我们使用FlinkSQL客户端执行sql的时候，报下图错误：

Flink SQL> CREATE TABLE test_input (
>      id STRING primary key,
>      name STRING,
>      type STRING
> ) WITH (
>   ‘connector’ = ‘jdbc’,
>   ‘url’ = ‘jdbc:mysql://localhost:3306/cdc’,
>   ‘username’ = ‘root’,
>   ‘password’ = ‘root’,
>   ‘table-name’ = ‘cdc_test’
> );
[INFO] Execute statement succeed.

Flink SQL> select * from test_input;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier ‘jdbc’ that implements ‘org.apache.flink.table.factories.DynamicTableFactory’ in the classpath.

Available factory identifiers are:

blackhole
data

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

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

相关推荐