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

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Won't Fix
• Affects Version/s: 1.11.3
• Component/s: Table SQL / Ecosystem
• Assignee: Unassigned
• Reporter: Phil Chen
• Created: 11/Apr/21 14:37
• Updated: 12/Apr/21 10:10
• Resolved: 12/Apr/21 10:10

Description

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>