liu zhuang created FLINK-23152:
----------------------------------

             Summary: Flink - {"errors":["Service temporarily unavailable due 
to an ongoing leader election. Please refresh."]}
                 Key: FLINK-23152
                 URL: https://issues.apache.org/jira/browse/FLINK-23152
             Project: Flink
          Issue Type: Bug
          Components: Deployment / YARN
    Affects Versions: 1.12.1
         Environment: Apache Hadoop Yarn version is 3.11

Apache Zookeeper version is 3.5.5
            Reporter: liu zhuang
         Attachments: jobmanager log.png

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]" 

{color:#FF0000}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.{color}

Please help to fix the issue with UI and HA.

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to