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/

回复