Hi, 有更详细的日志吗?看起来是类加载冲突的,需要明确下是哪个类冲突了
Best, Weihua On Wed, Jul 6, 2022 at 1:53 PM RS <tinyshr...@163.com> wrote: > 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