在我們使用FlinkSQL客戶端執(zhí)行sql的時(shí)候,報(bào)下圖錯(cuò)誤:
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:文章來(lái)源:http://www.zghlxwxcb.cn/news/detail-779749.html
blackhole
data文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-779749.html
到了這里,關(guān)于【Flink】ValidationException: Could not find any factory for identifier ‘jdbc‘ that implements ‘org.ap的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!