Flink 版本: 1.14.2

HA集群环境规划

使用三台节点实现两主两从集群

Jobmanager：node1,node2 一个active，一个standby

Taskmanager：node1,node2

Zookeeper: node1,node2,node3

配置+启动

配置

node1

masters

node1:2181
node2:2181

flink-conf.yaml

high-availability: zookeeper
high-availability.zookeeper.quorum: node1:2181,node2:2181,node3:2181
high-availability.zookeeper.path.root: /flink
high-availability.cluster-id: /cluster_one
high-availability.storageDir: file:///home/user/apps/flink-1.14.2/share

jobmanager.rpc.address: node1

高版本中high-availability为high-availability.type

high-availability.storageDir为URI形式,需要每个JobManger都能访问
这里通过NFS实现,NFS配置见: NFS 原理及安装

将配置复制到node2

启动

./start-cluster.sh