Hi,

通过sql-client执行flink sql,connector选择filesystem,会出现如下报错
java.lang.ClassNotFoundException: 
org.apache.flink.table.planner.delegation.ParserFactory


Flink SQL> CREATE TABLE t1 (
> a STRING,
> b INT
> )WITH(
> 'connector'='filesystem',
> 'path'='/tmp/qwe',
> 'format'='csv',
> 'csv.ignore-parse-errors' = 'true',
> 'csv.allow-comments' = 'true'
> );
[INFO] Execute statement succeed.
Flink SQL> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: 
org.apache.flink.table.planner.delegation.ParserFactory


我测试了下,是因为我的lib目录下,有 
flink-sql-connector-hive-3.1.2_2.12-1.15.0.jar,放lib下是因为还要其他任务需要读写hive
如果lib下没有flink-sql-connector-hive-3.1.2_2.12-1.15.0.jar,则没有这个报错


请教下,这个问题如何解决呢?


Thanks

回复