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