Phil Chen created FLINK-22200:
---------------------------------
Summary: 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 / Client
Affects Versions: 1.11.3
Reporter: Phil Chen
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)
