Hi,
只有 flink-table-planner-loader-1.15.1.jar,没有flink-table-planner_2.12-1.15.1.jar 也是不行的,并不是去掉一个就可以了 只能使用flink-table-planner_2.12-1.15.1.jar,所以感到奇怪 Thanks 在 2022-07-11 20:19:01,"jiangjiguang719" <jiangjiguang...@163.com> 写道: >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