[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564348#comment-17564348
]
Jesus H Christ commented on FLINK-27357:
----------------------------------------
Yes, that would be the correct solution. I will demonstrate in PR if I can find
the time.
> In Flink HA Service on K8S, Web UI External Service should point to elected
> Job Manager leader's IP
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-27357
> URL: https://issues.apache.org/jira/browse/FLINK-27357
> Project: Flink
> Issue Type: Improvement
> Reporter: Jesus H Christ
> Priority: Minor
>
> Flink on Kubernetes has High Availability services which build an external
> service for the rest api access.
> [https://sourcegraph.com/github.com/apache/flink@master/-/blob/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/ExternalServiceDecorator.java]
> In the case of multiple job managers in reactive mode or to avoid 15s or so
> between job manager restarts in K8S High Availability services, a new job
> manager leader can be elected. In this case I think the external service we
> create for the web ui, and possibly even the REST API service, no longer
> points to the correct job manager as any of the job manager pods can have the
> jobmanager label. Is this correct?
> If so, it might help to use the endpoint containing the elected leader IP in
> the ConfigMap of one specific pod of the JobManager for the external service
> web ui, similar to how TaskManagers use JobManager IPs for High Availabiilty.
>
> It might also help to update the service or endpoint with the new IP to
> point to when updating the ConfigMap for JobManager leader election:
> [https://sourcegraph.com/github.com/apache/flink/-/blob/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderRetrievalDriverFactory.java]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
