[FLINK-23152] Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Won't Fix
• Affects Version/s: 1.12.1
• Component/s: Deployment / YARN

Environment

Apache Hadoop Yarn version is 3.11

Apache Zookeeper version is 3.5.5

• Assignee: Unassigned
• Reporter: Zhuang Liu
• Created: 25/Jun/21 04:23
• Updated: 01/Dec/21 12:34
• Resolved: 01/Jul/21 09:45

Description

Hi Team,

I deployed  Flink  cluster on yarn-application mode.. JobManager HA with Apache ZooKeeper to deploy .. I use the following command to submit the flink job ,

 

flink run-application -t yarn-application \
-c com.model \
-Djobmanager.memory.process.size=1024m \
-Dtaskmanager.memory.process.size=1024m \
-Dyarn.provided.lib.dirs="hdfs:///user/flink/libs;hdfs:///user/flink/plugins" \
-Dyarn.application.name="test" \
hdfs:///user/flink/jars/model-1.0.jar

 

But Flink Web UI is throwing an error saying

"

{"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

".

 

In the  zookeeper node ，this flink job is "[jobgraphs,leader,leaderlatch]" 

Attached is the jobmanager log of this flink job. At the same time, when I use the Flink Per-job mode to submit the job, it can run normally.

Please help to fix the issue with UI and HA.