运行验证
- 依次启动ZooKeeper和Hadoop。
- 在server1上启动Flink。
1
/usr/local/flink/bin/yarn-session.sh -nm flinkapp
- yarn-session.sh详细参数可执行如下命令查看。
1
/usr/local/flink/bin/yarn-session.sh -h
- 在server1上停止Flink集群可执行如下命令。
1
yarn app -kill $(yarn app -list | grep flinkapp | awk '{print $1}')
- yarn-session.sh详细参数可执行如下命令查看。
- Yarn Session启动后生成一个Yarn Application ID,可通过Yarn Web UI访问至Flink Web UI。访问地址如下,可根据实际情况修改。例如Yarn Session启动之后生成的“Application ID”为“application_XX_XX”,Yarn Web UI端口号为8088,集群主节点IP地址为server1,则访问以下地址即可。
http://server1:8088/proxy/Application ID/
- 使用如下命令查询Yarn Web UI端口号,若查询不到端口号即为默认端口号8088。
1
cat /usr/local/hadoop/etc/hadoop/yarn-site.xml | grep "yarn.resourcemanager.webapp.address" -A 1
- Application ID查询方式:登录Yarn Web UI,在“Search”搜索框中搜索关键字flinkapp。
- 使用如下命令查询Yarn Web UI端口号,若查询不到端口号即为默认端口号8088。
父主题: 部署Flink(on yarn模式)