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 就可以了
评论