[FLINK-36264] Fix can not setup other values for parameter rest-service.exposed.type

Author: chenyuzhi459

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java

@@ -249,16 +249,6 @@ protected FlinkConfigBuilder applyPodTemplate() throws IOException {
         return this;
     }
 
-    protected FlinkConfigBuilder applyIngressDomain() {
-        // Web UI
-        if (spec.getIngress() != null) {
-            effectiveConfig.set(
-                    REST_SERVICE_EXPOSED_TYPE,
-                    KubernetesConfigOptions.ServiceExposedType.ClusterIP);
-        }
-        return this;
-    }
-
     protected FlinkConfigBuilder applyServiceAccount() {
         if (spec.getServiceAccount() != null) {
             effectiveConfig.set(
@@ -412,7 +402,6 @@ public static Configuration buildFrom(
                 .applyImagePullPolicy()
                 .applyServiceAccount()
                 .applyPodTemplate()
-                .applyIngressDomain()
                 .applyJobManagerSpec()
                 .applyTaskManagerSpec()
                 .applyJobOrSessionSpec()

flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java

@@ -63,6 +63,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Stream;
 
 import static org.apache.flink.configuration.DeploymentOptions.SHUTDOWN_ON_APPLICATION_FINISH;
 import static org.apache.flink.kubernetes.operator.api.utils.BaseTestUtils.IMAGE;
@@ -348,17 +349,6 @@ private PodTemplateSpec getTmPod(Configuration configuration) throws IOException
                 PodTemplateSpec.class);
     }
 
-    @Test
-    public void testApplyIngressDomain() {
-        final Configuration configuration =
-                new FlinkConfigBuilder(flinkDeployment, new Configuration())
-                        .applyIngressDomain()
-                        .build();
-        assertEquals(
-                KubernetesConfigOptions.ServiceExposedType.ClusterIP,
-                configuration.get(KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE));
-    }
-
     @Test
     public void testApplyServiceAccount() {
         final Configuration configuration =
@@ -944,4 +934,13 @@ private PodTemplateSpec createTestPodWithContainers() {
                 TestUtils.getTestPodTemplate("hostname", List.of(mainContainer, sideCarContainer));
         return pod;
     }
+
+    private static Stream<KubernetesConfigOptions.ServiceExposedType> serviceExposedTypes() {
+        return Stream.of(
+                null,
+                KubernetesConfigOptions.ServiceExposedType.ClusterIP,
+                KubernetesConfigOptions.ServiceExposedType.LoadBalancer,
+                KubernetesConfigOptions.ServiceExposedType.Headless_ClusterIP,
+                KubernetesConfigOptions.ServiceExposedType.NodePort);
+    }
 }