centos7搭建flink1.18并以 standalone模式启动

版本

关于scala和Java的安装参考：scala和java安装

flink 下载地址：flink下载链接

集群规划

安装

1.创建存放路径
三个节点都需要操作

用于存放安装包: mkdir /home/software/
用于存放存放解压后的模块： mkdir /opt/module/bin/
用于存放模块软链接： mkdir /opt/module/link/

2.上传安装包
三个节点都需要操作
将安装包【flink-1.18.1-bin-scala_2.12.tgz】上传至/home/software/目录下

3.解压 压缩包
三个节点都需要操作

tar -zxvf /home/software/flink-1.18.1-bin-scala_2.12.tgz -C /opt/module/bin/

4.修改配置文件
三个节点都需要操作
配置文件路径：/opt/module/bin/flink-1.18.1/conf
修改文件： vi master
添加内容：

bigdata01:8081

修改文件： vi workers
添加内容：

bigdata01
bigdata02
bigdata03

修改文件： vi flink-conf.yaml
修改内容：

jobmanager.rpc.address: bigdata01 # jobmanager地址
jobmanager.bind-host: 0.0.0.0     # jobmanager绑定地址
taskmanager.bind-host: 0.0.0.0    # taskmanager绑定地址
# taskmanager地址，写当前修改文件的节点地址
taskmanager.host: bigdata01       

taskmanager.numberOfTaskSlots: 4   # 任务槽数 ，根据需求填写
parallelism.default: 4  # 并行度 ，根据需求填写
execution.checkpointing.interval: 5000 # checkpoint时间间隔，毫秒
rest.port: 8081              #  REST服务的端口
rest.address: bigdata01      #  REST服务的地址
rest.bind-address: 0.0.0.0   # REST服务的绑定地址

5.启动flink

./opt/module/bin/flink-1.18.1/bin/start-cluster.sh

三个节点分别执行jps查看
bigdata01节点出现 【StandaloneSessionClusterEntrypoint】进程
bigdata01,bigdata02,bigdata03节点都出现【TaskManagerRunner】进程

则表示启动成功

访问 http://bigdata01:8081,出现

6.如果启动失败
查看/opt/module/bin/flink-1.18.1/log目录下的最新日志，查看具体错误，针对解决。