我们通过config flink-com.yaml实现了它。
high-availability = zookeeper
high-availability.zookeeper.quorum=zk1:2181
high-availability.zookeeper.path.root=/flinkha
high-availability.cluster-id=/flink1
high-availability.storageDir=file:///opt/flink/data/flink1/recovery
high-availability.jobmanager.port = 6070
high-availability.zookeeper.client.acl=open
我们可以通过设置环境变量来实现flink zk ha吗?似乎我们传递了变量,它不能工作。
"-Dhigh-availability=zookeeper","-Dhigh-availability.zookeeper.quorum=zk-0.zk-hs:2181,zk-1.zk-hs:2181,zk-2.zk-hs:2181","-Dhigh-availability.zookeeper.path.root=/flinkha","-Dhigh-availability.cluster-id=/flr20","-Dhigh-availability.storageDir=file:///opt/flink/data/flr20/recovery","-Dhigh-availability.jobmanager.port=6070","-Dhigh-availability.zookeeper.client.acl=open"
暂无答案!
目前还没有任何答案,快来回答吧!