[FLINK-26356] Directly use service name to make up rest endpoint

This closes apache#25.
HuangZhenQiu · Feb 28, 2022 · a5ecd44 · a5ecd44
1 parent 684b459
commit a5ecd44
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...tes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java b/...tes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java
@@ -32,6 +32,7 @@
 import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.kubernetes.configuration.KubernetesConfigOptions;
 import org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient;
+import org.apache.flink.kubernetes.kubeclient.decorators.ExternalServiceDecorator;
 import org.apache.flink.kubernetes.operator.crd.FlinkDeployment;
 import org.apache.flink.kubernetes.operator.crd.spec.JobSpec;
 import org.apache.flink.kubernetes.operator.crd.spec.UpgradeMode;
@@ -131,8 +132,7 @@ protected ClusterClient<String> getClusterClient(Configuration config) throws Ex
         final String namespace = config.get(KubernetesConfigOptions.NAMESPACE);
         final int port = config.getInteger(RestOptions.PORT);
         final String host =
-                config.getString(
-                        RestOptions.ADDRESS, String.format("%s-rest.%s", clusterId, namespace));
+                ExternalServiceDecorator.getNamespacedExternalServiceName(clusterId, namespace);
         final String restServerAddress = String.format("http://%s:%s", host, port);
         LOG.debug("Creating RestClusterClient({})", restServerAddress);
         return new RestClusterClient<>(