一. 环境准备
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的端口,如下图所示代表部署成功