1. 这里用三台机器测试,需要jdk1.8支持,没有的可以自己去下载安装,我就不放教程了
  2. 准备好安装包,官网下载地址:
    https://flink.apache.org/zh/downloads.html
  3. 依次上传到服务器上
  4. 解压
1
tar -zxvf flink-1.12.4-bin-scala_2.12.tgz
  1. 依次修改conf目录下的flink-conf.yaml文件
1
jobmanager.rpc.address: 主节点ip(JobManager)
  1. 修改conf下的masters
1
主节点ip:8081
  1. 修改conf下的workers
1
2
从节点ip
从节点ip
  1. 在主节点上启动
1
./bin/start-cluster.sh
  1. 登录web界面,可以看到到这里就安装成功了