flink sql报错: Could not find any format factory for

Hi:

在使用flink sql connector的filesytem时，指定format为parquet。抛出异常信息

Caused by: org.apache.flink.table.api.ValidationException: Could not find any format factory for identifier 'parquet' in the classpath.

at org.apache.flink.table.filesystem.FileSystemTableSource. (FileSystemTableSource.java:97)

at org.apache.flink.table.filesystem.FileSystemTableFactory.createDynamicTableSource(FileSystemTableFactory.java:72)

at org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:119)

... 41 more

Sql语句如下：

CREATE TABLE user_info (

user_id bigint,

user_name string

) PARTITIONED BY (user_id) WITH (

'connector' = 'filesystem',

'path' = '',

'format' = 'parquet'

);

CREATE TABLE sink_table (

user_id bigint,

user_name string

) PARTITIONED BY (datetime) WITH (

'connector'='filesystem',

'path'='',

'format'='parquet',

'sink.partition-commit.delay'='1h',

'sink.partition-commit.policy.kind'='success-file'

);

insert OVERWRITE sink_table select *, '2021062600' as datetime from user_info;*来自志愿者整理的flink邮件归档