[FLINK-16601] Correct the way to get Endpoint address for NodePort rest Service

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Component/s: Deployment / Kubernetes
• Labels: auto-unassigned
• Assignee: Unassigned
• Reporter: Canbin Zheng
• Created: 15/Mar/20 06:35
• Updated: 15/Feb/22 03:51
• Resolved: 15/Feb/22 03:51

Description

Currently, if one sets the type of the rest-service to NodePort, then the way to get the Endpoint address is by calling the method of KubernetesClient.getMasterUrl().getHost(). This solution works fine for the case of the non-managed Kubernetes cluster but not for the managed ones.

For the managed Kubernetes cluster setups, the Kubernetes masters are deployed in a pool different from the Kubernetes nodes and the master node does not expose a NodePort for the NodePort Service.

Issue Links

• duplicates: FLINK-21840 can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort
• is fixed by: FLINK-23507 The node IP obtained in NodePort mode is a VIP