Flink集群搭建--StandAlone

Flink集群搭建--StandAlone

清泓
2022-06-06 / 0 评论 / 3,794 阅读 / 1795字 / 正在检测是否收录...

前期准备

安装包下载:http://archive.apache.org/dist/flink/flink-1.10.2/
1

独立部署模式搭建

解压

[root@master ~]# tar -zxvf /data/flink-1.10.2 -C /usr/local/src/
[root@master ~]# mv /usr/local/src/flink-1.10.2 /usr/local/src/flink

配置环境变量

[root@master ~]# vi /etc/profile
  export FLINK_HOME=/usr/local/src/flink
  export PATH=$PATH:$FLINK_HOME/bin
[root@master ~]# source /etc/profile

集群架构

2

修改配置文件

[root@master ~]# vi /usr/local/src/flink/conf/flink-conf.yaml
  # (修改)指定主节点ip地址
  jobmanager.rpc.address: master

[root@master ~]# vi /usr/local/src/flink/conf/workers
  # (修改)指定从节点
  slave1 
  slave2

[root@master ~]# vi /usr/local/src/flink/conf/masters 
  # 改成主节点master
  master:8081

分发

[root@master ~]# scp -r /usr/local/src/flink slave1:/usr/local/src/
[root@master ~]# scp -r /usr/local/src/flink slave2:/usr/local/src/

启动(停止)集群

Flink集群的命令都在 bin 目录下,所有主从架构的集群都是在主节点操作命令

# 启动
[root@master ~]# start-cluster.sh
# 停止
[root@master ~]# stop-cluster.sh

提交作业(job)

[root@master ~]# flink run -c com.test.WordCount /data/flink-1.0.jar 

com.test.WordCount -- 主类名
/data/flink-1.0.jar -- jar包路径

访问Flink web界面

http://master节点ip:8081
3
4
5

0

打赏

评论

博主关闭了当前页面的评论