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

回复