[
https://issues.apache.org/jira/browse/FLINK-23152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369252#comment-17369252
]
Matthias edited comment on FLINK-23152 at 12/1/21, 12:34 PM:
-------------------------------------------------------------
Hi [~liu zhuang], thanks for sharing the logs (even though, it would be helpful
to not share a screenshot but to share the actual text; your screenshot is hard
to read).
The error message you're seeing in the web UI is normal when electing a new
leader. Based on your screenshot it looks like there is a
{{NumberFormatException}} causing the error in your main method.
Another hint: It would be good to use the [user mailing
list|https://flink.apache.org/community.html#mailing-lists] for these kind of
questions.
was (Author: mapohl):
Hi [~liu zhuang], thanks for sharing the logs (even though, it would be helpful
to not share a screenshot but to share the actual text; you're screenshot is
hard to read).
The error message you're seeing in the web UI is normal when electing a new
leader. Based on your screenshot it looks like there is a
{{NumberFormatException}} causing the error in your main method.
Another hint: It would be good to use the [user mailing
list|https://flink.apache.org/community.html#mailing-lists] for these kind of
questions.
> 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
> Priority: Minor
> 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.20.1#820001)
