在我们使用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:文章来源:https://www.toymoban.com/news/detail-779749.html
blackhole
data文章来源地址https://www.toymoban.com/news/detail-779749.html
到了这里,关于【Flink】ValidationException: Could not find any factory for identifier ‘jdbc‘ that implements ‘org.ap的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!