[ 
https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652511#comment-17652511
 ] 

Biao Geng commented on FLINK-30518:
-----------------------------------

I think [~gyfora] is right that this is not a problem before.
I just tried an older version(1.1.0) of the operator with setting replicas to 2 
for jobManager and it works fine on running jobs and accessing web ui. 
I checked my configmap(`basic-checkpoint-ha-example-cluster-config-map`) and it 
seems that leader.dispatcher is set correctly.
 !screenshot-1.png! 

I will try to reproduce this problem with the image of the operator based on 
the latest main branch as the 
[PR|https://github.com/apache/flink-kubernetes-operator/pull/494] to remove 
read-only limt is merged.

> [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address
> ------------------------------------------------------------------------------
>
>                 Key: FLINK-30518
>                 URL: https://issues.apache.org/jira/browse/FLINK-30518
>             Project: Flink
>          Issue Type: Bug
>          Components: Kubernetes Operator
>    Affects Versions: kubernetes-operator-1.3.0
>            Reporter: Binh-Nguyen Tran
>            Priority: Major
>         Attachments: flink-configmap.png, screenshot-1.png
>
>
> Since flink-conf.yaml is mounted as read-only configmap, the 
> /docker-entrypoint.sh script is not able to inject correct Pod IP to 
> `jobmanager.rpc.address`. This leads to same address (e.g flink.ns-ext) being 
> set for all Job Manager pods. This causes:
> (1) flink-cluster-config-map always contains wrong address for all 3 
> component leaders (see screenshot, should be pod IP instead of clusterIP 
> service name)
> (2) Accessing Web UI when jobmanager.replicas > 1 is not possible with error
> {code:java}
> {"errors":["Service temporarily unavailable due to an ongoing leader 
> election. Please refresh."]} {code}
>  
> ~ flinkdeployment.yaml ~
> {code:java}
> spec:
>   flinkConfiguration:
>     high-availability: kubernetes
>     high-availability.storageDir: "file:///opt/flink/storage"
>     ...
>   jobManager:
>     replicas: 3
>   ... {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to