[incubator-streampark] branch dev updated: fix getService bug (#3031)

[linying]

This is an automated email from the ASF dual-hosted git repository.

linying pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0049916a7 fix getService bug (#3031)
0049916a7 is described below

commit 0049916a768e688c3bb8dc76a6d466968940ba5a
Author: xiebin <xbth...@qq.com>
AuthorDate: Wed Sep 13 14:15:40 2023 +0800

    fix getService bug (#3031)
---
 .../scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala | 3 ++-
 .../scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
 
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
index f388c8e9f..e643cba90 100644
--- 
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
+++ 
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
@@ -17,6 +17,7 @@
 package org.apache.streampark.flink.core
 
 import org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
+import 
org.apache.flink.kubernetes.kubeclient.decorators.ExternalServiceDecorator
 import org.apache.flink.kubernetes.kubeclient.resources.KubernetesService
 
 import java.util.Optional
@@ -25,7 +26,7 @@ class FlinkKubernetesClient(kubeClient: FlinkKubeClient)
   extends FlinkKubernetesClientTrait(kubeClient) {
 
   override def getService(serviceName: String): Optional[KubernetesService] = {
-    kubeClient.getService(serviceName)
+    
kubeClient.getService(ExternalServiceDecorator.getExternalServiceName(serviceName))
   }
 
 }
diff --git 
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
 
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
index f388c8e9f..e643cba90 100644
--- 
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
+++ 
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClient.scala
@@ -17,6 +17,7 @@
 package org.apache.streampark.flink.core
 
 import org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
+import 
org.apache.flink.kubernetes.kubeclient.decorators.ExternalServiceDecorator
 import org.apache.flink.kubernetes.kubeclient.resources.KubernetesService
 
 import java.util.Optional
@@ -25,7 +26,7 @@ class FlinkKubernetesClient(kubeClient: FlinkKubeClient)
   extends FlinkKubernetesClientTrait(kubeClient) {
 
   override def getService(serviceName: String): Optional[KubernetesService] = {
-    kubeClient.getService(serviceName)
+    
kubeClient.getService(ExternalServiceDecorator.getExternalServiceName(serviceName))
   }
 
 }