[
https://issues.apache.org/jira/browse/FLINK-22200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22200:
----------------------------
Component/s: (was: Table SQL / Client)
Table SQL / Ecosystem
> Flink SQL Client Error with: Could not find any factory for identifier 'hudi'
> that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory
> ---------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-22200
> URL: https://issues.apache.org/jira/browse/FLINK-22200
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Ecosystem
> Affects Versions: 1.11.3
> Reporter: Phil Chen
> Priority: Blocker
>
> When use hudi-flink with Flink SQL to perform stream read. The Flink SQL
> client failed to submit job with the following error:
> Flink version: 1.11.3
> Hadoop version 2.10.1
> hudi-flink: hudi-flink-bundle_2.11-0.8.0.jar
> Flink SQL> create table t1(
> > uuid varchar(20),
> > name varchar(10),
> > age int,
> > ts timestamp(3),
> > `partition` varchar(20)
> > )
> > PARTITIONED BY (`partition`)
> > with (
> > 'connector' = 'hudi',
> > 'path' = 'file:///hudi/t1',
> > 'table.type' = 'MERGE_ON_READ',
> > 'read.streaming.enabled' = 'true',
> > 'read.streaming.check-interval' = '4'
> > );
> [INFO] Table has been created.
> Flink SQL> set execution.result-mode=tableau;
> [INFO] Session property has been set.
> Flink SQL> select * from t1;
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.table.api.ValidationException: Could not find any factory
> for identifier 'hudi' that implements
> 'org.apache.flink.table.factories.DynamicTableSourceFactory' in the classpath.
> Available factory identifiers are:
> datagen
> Flink SQL>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
