FlinkonYarn安装

步骤很简单&＃xff0c;既然要基于yarn&＃xff0c;前提是hadoop已经安装好了&＃xff0c;我们选择hadoop集群的一个节点&＃xff0c;安装一个flink客户端即可。我们平时提交任务&＃xff0c;包括mr、spark任务等&＃xff0c;也会去安装一个spark客户端。

选择一个节点&＃xff0c;这个节点通常会用它提交任务。

下载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&＃61;/etc/hadoop/conf
export HADOOP_CLASSPATH&＃61;&＃96;hadoop classpath&＃96;


启动一个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。