把flink parquet包放在flink客户端lib包下试试呢
原始邮件
发件人: Wei JI10 季伟<wei.j...@nio.com.INVALID>
收件人: user-zh@flink.apache.org<user-zh@flink.apache.org>
发送时间: 2021年6月28日(周一) 14:14
主题: Re: flink sql报错: Could not find any format factory for identifier 'parquet'
in the classpath
您好，
我没有设置scope，我看jar包中是有org/apache/flink/formats/parquet/这个目录的...
在 2021/6/28
下午12:47，“zhisheng”<zhisheng2...@gmail.com<mailto:zhisheng2...@gmail.com>> 写入:
注意：此封邮件来自于公司外部，请注意信息安全！
Attention: This email comes from outside of the company, please pay
attention to the information security!
看下你引入的 jar 包是咋引入的，scope 设置的是 provided 吧？
Wei JI10 季伟 <wei.j...@nio.com.invalid<mailto:wei.j...@nio.com.invalid>>
于2021年6月28日周一 下午12:19写道：
> 您好，
> 版本都是1.12.3的，有其他方式能够定位到这个问题出在哪么？
>
> 在 2021/6/28 上午11:59，“Jingsong
Li”<jingsongl...@gmail.com<mailto:jingsongl...@gmail.com>> 写入:
>
> 注意：此封邮件来自于公司外部，请注意信息安全！
> Attention: This email comes from outside of the company, please pay
> attention to the information security!
>
> Hi, 你的版本check下？集群和flink-parquet是同一个版本吗？
>
> BEST，
> Jingsong
>
> On Mon, Jun 28, 2021 at 11:22 AM Wei JI10 季伟
<wei.j...@nio.com.invalid<mailto:wei.j...@nio.com.invalid>
> >
> wrote:
>
> > 您好，
> > 不是sql client，是在yarn环境上跑的，运行的jar包中引入了上面的依赖,然后就看到有这个报错。
> >
> >
>
> --
> Best, Jingsong Lee
>
>
