(incubator-streampark) branch dev-2.1.3 updated: [Improve] ingress minor improvement

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 7785ceeee [Improve] ingress minor improvement
7785ceeee is described below

commit 7785ceeeed4b2383a780b6440e589e7b0b652552
Author: benjobs <benj...@gmail.com>
AuthorDate: Sat Jan 27 16:28:14 2024 +0800

    [Improve] ingress minor improvement
---
 .../flink/kubernetes/ingress/IngressController.scala     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala
 
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala
index 7e82f996a..8bf576329 100644
--- 
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala
+++ 
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala
@@ -29,15 +29,15 @@ object IngressController extends Logger {
 
   private[this] val VERSION_REGEXP = "(\\d+\\.\\d+)".r
 
+  private lazy val clusterVersion = using(new DefaultKubernetesClient()) {
+    client => 
VERSION_REGEXP.findFirstIn(client.getVersion.getGitVersion).get.toDouble
+  }
+
   private lazy val ingressStrategy: IngressStrategy = {
-    using(new DefaultKubernetesClient()) {
-      client =>
-        val version = 
VERSION_REGEXP.findFirstIn(client.getVersion.getGitVersion).get.toDouble
-        if (version >= 1.19) {
-          new IngressStrategyV1()
-        } else {
-          new IngressStrategyV1beta1()
-        }
+    if (clusterVersion >= 1.19) {
+      new IngressStrategyV1()
+    } else {
+      new IngressStrategyV1beta1()
     }
   }