hi 可以检查一下提交任务的 flink 客户端的 lib 目录下面是否有 flink-sql-parquet_2.11-1.12.0.jar 依赖
Best zhisheng 冯嘉伟 <1425385...@qq.com> 于2021年1月4日周一 上午9:58写道： > hi! > > java.io.FileNotFoundException: File file:/home/xjia/.flink/... > 可以看出，从本地加载jar包，而不是hdfs。 > > 我觉得可能是hadoop环境的问题，导致读取的scheme是file，使用 echo $HADOOP_CLASSPATH 检查你的环境。 > > Important Make sure that the HADOOP_CLASSPATH environment variable is set > up > (it can be checked by running echo $HADOOP_CLASSPATH). If not, set it up > using > > > https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/yarn.html > < > https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/yarn.html> > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
