// 上一次似乎没发成功，换个方式重发一次，若有打扰请见谅
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 -- Sent from: http://apache-flink.147419.n8.nabble.com/
