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

回复