HADOOP_CLASSPATH 看下环境变量的内容是什么,是否和 "hadoop classpath" 这个语句执行的结果一致?
根据 [1],Flink 1.11 开始,不再默认把 HDFS 相关的 jar 包打进 Flink 的包里面了,而是需要用户在执行时指定 HDFS 
相关包路径,export HADOOP_CLASSPATH=`hadoop classpath` 这句话实际上的效果是执行 hadoop classpath 
命令并将结果赋值给 HADOOP_CLASSPATH 这个系统变量。

另外控制变量的话你找个最简单的作业提交一下看看?
看上面的错误日志你提交的应该是个 SQL 作业,找个 DataStream 的 word count 提交看下报错信息是什么。

参考:
[1]. 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/yarn.html

回复