步骤很简单，既然要基于yarn，前提是hadoop已经安装好了，我们选择hadoop集群的一个节点，安装一个flink客户端即可。我们平时提交任务，包括mr、spark任务等，也会去安装一个spark客户端。
选择一个节点，这个节点通常会用它提交任务。
下载flink
wget http://archive.apache.org/dist/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz
解压
tar -zxvf flink-1.13.5-bin-scala_2.11.tgz
配置环境
export HADOOP_CONF_DIR=/etc/hadoop/conf export HADOOP_CLASSPATH=`hadoop classpath`
启动一个flink-session
bin/yarn-session.sh -d -s 2 -jm 1024 -tm 2048 -qu [yarn队列名] -nm wordcount
比如这里生成了一个application_1633924491541_2461
进入yarn界面
http://cdh-003:8088/cluster/scheduler
点击对应application。
