Re: 答复: Best way to find the current alive jobmanager with HA mode zookeeper

Hi Martin, when configuring Flink to use the ZooKeeper HA mode, then it won't be necessary to specify the leader's address manually. The CLI will ask ZooKeeper for the leader information and send the request to the current leader. This should work with at least Flink >= 1.5 and also with Flink 1.4

Re: 答复: Best way to find the current alive jobmanager with HA mode zookeeper

Hi guys, Just to close the loop, with the Flink 1.3.2 cli you have to provide the Flink Job Manager host address in order to submit a job like so: ${FLINK_HOME}/bin/flink run -d -m ${FLINK_JOBMANAGER_ADDRESS} ${JOB_JAR} Since we are running the DCOS Flink package we use the Marathon rest api to f

Re: 答复: Best way to find the current alive jobmanager with HA mode zookeeper

I think that the web ui automatically redirects to the current leader. So if you should access the JobManager which is not leader, then you should get an HTTP redirect to the current leader. Due to that it should not be strictly necessary to know which of the JobManagers is the leader. The RestClu

Re: 答复: Best way to find the current alive jobmanager with HA mode zookeeper

Hi Youjun, Thanks, you can try this but I am not sure if it works correctly. Because for the REST Client, there are quite a few changes from 1.4 to 1.5. Maybe you can customize the source code in 1.4 refer to specific implementation of 1.5? Another option, upgrade your Flink version. To Chesnay

答复: Best way to find the current alive jobmanager with HA mode zookeeper

Thanks for the information. Forgot to mention, I am using Flink 1.4, the RestClusterClient seems don’t have the ability to retrieve the leader address. I did notice there is webMonitorRetrievalService member in Flink 1.5. I wonder if I can use RestClusterClient@v1.5