[jira] [Created] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory

[Shang Yuanchun (Jira)]

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)