[FLINK-26356] Revisit the create of RestClusterClient

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: kubernetes-operator-0.1.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• Assignee: WenJun Min
• Reporter: WenJun Min
• Created: 24/Feb/22 14:37
• Updated: 27/Mar/22 13:16
• Resolved: 28/Feb/22 06:18

Description

The clusterClient is built as below. The config is mixed up with the FlinkDeploymentSpec and local default config. 

final int port = config.getInteger(RestOptions.PORT);
final String host =
        config.getString(
                RestOptions.ADDRESS, String.format("%s-rest.%s", clusterId, namespace));
final String restServerAddress = String.format("http://%s:%s", host, port); 

But the RestOptions.ADDRESS is generated at the entrypoint when the HA is enabled, so the option can not obtain from the FlinkDeploymentSpec.

Furthermore, the default rest url is not suitable for all the service type. I think we should extract the rest endpoint from the Flink external service.

Issue Links

• links to: GitHub Pull Request #25