使用flink在yarn上创建一个session,创建的时候会提示slf4j的jar包无法找到,原因是flink默认就是需要系统中有一个HADOOP_HOME的环境变量。
yarn-session.sh -n 2 -jm 1024 -tm 1024 -d
session启动后,使用flink提交任务
flink run /opt/flink-1.7.2/examples/batch/WordCount.jar -input hdfs://192.168.13.128:9000/input/myfile.txt -output hdfs://192.168.13.128:9000/output/result.txt
会发现任务始终无法提交成功,在yarn的配置中将vmem-check改成false,就能运行成功