1.概述

本文章是我在做这个的时候遇见的：Flink The file LOG does not exist on the TaskExecutor

提交任务命令如下

  su - hdfs -c "export HADOOP_CONF_DIR=/usr/xxxx/hadoop/conf && export FLINK_CONF_DIR=/usr/hdp/xxx/xxx/flink/conf  && export HADOOP_CLASSPATH=`hadoop classpath` && $basepath/bin/flink run -class ${mainclass} $basepath/engine/xxx-${solution_name}-*.jar   ${job_name} -m yarn-cluster   -ynm ${job_name}  -yjm ${jm_mem} -ytm ${tm_mem} -yD env.java.opts='${jvm_options}'  -ys ${slots_pertm} -yd