- flink conf/flink-conf.yaml
high-availability: zookeeper (必须)
high-availability.zookeeper.quorum: flink-01:2181,flink-02:2181,flink-03:2181(必须)
high-availability.zookeeper.path.root: /flink (可选)
high-availability.storageDir: hdfs:///flink/ha(必须)
yarn.application-attempts: 10 (必须) -
yarn-site 也需要修改,可以修改为5
image.png
网友评论