hi, 你这个问题是， flink-table-planner-loader-1.15.1.jar 和 flink-table-planner_2.12-1.15.1.jar 冲突了 去掉一个就可以了
在 2022-07-11 19:45:04，"Weihua Hu" <huweihua....@gmail.com> 写道： >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
