一. 环境准备
1、下载并安装jdk11
2、下载flink 并解压
3、确保服务器之间的免密登录
二、集群搭建
搭建集群至少有三台机器,每台机器的分配角色如下
master: jobManager
salve01:taskManager
salve02:taskManager
1、在JobManager(master)服务器上下载并解压flink安装包,解压后的flink目录如下

2. 进入conf文件夹下修改config.yaml配置
修改 jobManager.rpc.bind-host为0.0.0.0 ,rpc.address为master服务的ip

如果想访问flink的web页面需要把下面的配置也改下

3、修改 workers文件, 内容为taskManager的ip

4.、将安装包复制到另外两台的 taskManager中,并修改cofig.yaml文件的JobManager部分,把ip改为jobManager的地址

5、 去master服务器上启动flink,位置在flink的bin文件夹下,执行下面的脚本就可以
如果返回这个代表成功,

6、打开web页面地址为jobManager的ip+8081的端口,如下图所示代表部署成功
