前言
flink安装部署有三种方式
-
local:单机模式，尽量不使用
-
standalone: flink自带集群，资源管理由flink集群管理，开发环境测试使用，不需要hadoop集群
-
flink on yarn: 把资源管理交给yarn实现，计算机资源统一由Haoop YARN管理，生产环境测试，需要先启动hadoop集群。（这里分为可以继续细分三种方式
1.session mode 长久启动一个flink集群接收job,main 方法在客户端执行
2.per-job mode 每个任务启动一个flink集群,main 方法在客户端执行
3.application mode Application 模式为每个提交的应用程序创建一个集群，该集群可以看作是在特定应用程序的作业之间共享的会话集群，并在应用程序完成时终止
）
一、flink包选择以及下载
下载地址在下面
https://www.apache.org/dyn/closer.lua/flink/flink-1.17.0/flink-1.17.0-bin-scala_2.12.tgz
看flink适配的版本可以去看flink的版本说明，上flink官网
看这里的部署，yarn模式部署，这里可以看到要求hadoop最小的版本是多少
这里版本要求是大于2.10.2版本包括3.0版本，我的hadoop版本是满足要求的，直接安装这个最新的flink版本。
二、安装flink集群
因为我前面已经安装了hadoop集群，这里直接选择flink on yarn的安装方式，模式选择了session-mode方式，实际生产中使用per-job和application的模式可能会比较多，但是操作基本差不太多，就直接使用这种方式安装了。以下的操作需要集群每台机器都操作下，我这里
只是测试在hadoop1：192.168.184.129、hadoop2:192.168.184.130、hadooop3:192.168.184.131三台机器上部署。
2.1.上传压缩包到linux上
解压到你需要安装的目录
我的安装目录为/root/tools，这个可以自己定，执行以下命令
tar -zxvf flink-1.17.0-bin-scala_2.12.tgz
解压完成后得到flink安装目录
/root/tools/flink-1.17.0
2.2 修改linux环境变量
修改 /etc/profile文件，在文件末尾加上
export HADOOP_CLASSPATH=`hadoop classpath`
export FLINK_HOME=/root/tools/flink-1.17.0
export PATH=$PATH:$FLINK_HOME/bin
刷新环境变量
进入hadoop安装目录执行脚本，这里的hadoop安装就不在这里说了
可以去文章看。hadoop集群安装
./hadoop.sh start
2.3 启动flink集群
进入
/root/tools/flink-1.17.0 目录执行以下指令
./bin/yarn-session.sh --detached
出现以下日志说明启动成功。
flink集群关闭可以使用指令
./bin/yarn-session.sh -id application_1684894883560_0001
如果上面的停不了使用指令，id在hadoop上有显示，copy下就行。
yarn application -kill application_1684894883560_0001
2.4 查看集群
http://hadoop2:8088/cluster/nodes
登录hadoop集群管理页面，可以看到启动的flink集群。
点击右边的flink集群管理界面
flink集群管理界面
三、测试
3.1 提交flink的测试job看看结果
选择到wordcount.jar看看执行结果
提交任务
查看任务执行情况。
这里可以看到任务已经执行完毕了，这里的例子没找到输出在哪看，下个博客自己弄一个jar去测试下。
总结
实践了下，hadoop集成flink，操作不难，不对的可以指出，一起进步。
