FlinkFlink 本地 per-job 模式提交flink报错 Connection refused: localhost/127.0.0.1:8081

Posted 2022-08-31 九师兄

文章目录

• 1.概述

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