网站首页> 文章专栏> Flink Standalone HA高可用集群
Flink Standalone HA高可用集群
路人王 天津 144 0 0

1.三台节点:

hadoop1,hadoop2,hadoop3
jobmanager[active] jobmanager [standby] taskmanager taskmanager

2.zookeeper集群或者单节点

3.tar -zxvf ......jar

vi flink-conf.yaml
jobmanager.rpc.address: hadoop1
vi slaves
hadoop2
hadoop3

4.修改高可用的配置

vi conf/masters
hadoop1:8081
hadoop2:8081

5.

vi conf/flink-conf.yaml
high-avaiablity: zookeeper
high-avaiablity: zookeeper.quorum: hadoop1:2181,hadoop2:2181,hadoop3:2181
high-availablity.zookeeper.path.root: /flink
high-availablity.storageDir: hdfs://hadoop1:9000/flink/ha

6.拷贝修改的文件

scp -rq flink-1.6.1 hadoop2:$PWD
scp -rq flink-1.6.1 hadoop3:$PWD

7.启动路流程

如果是但单机的zookeeper,可以直接修改成zoo.cfg bin/zkServer.sh start
先启动hadoop zookeeper

启动HA集群

bin/start-cluster.sh 就可以了

评论

评论  分享  打赏