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/
