This is an automated email from the ASF dual-hosted git repository.
benjobs 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 205d9d46c add IngressClassName (#3511)
205d9d46c is described below
commit 205d9d46c1428b4a435ceade281bcbd6c9132946
Author: Bibo <[email protected]>
AuthorDate: Wed Jan 24 00:15:23 2024 +0800
add IngressClassName (#3511)
---
.../apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala | 2 ++
.../streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala | 2 ++
2 files changed, 4 insertions(+)
diff --git
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
index 17ac4b775..7212ba299 100644
---
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
+++
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
@@ -17,6 +17,7 @@
package org.apache.streampark.flink.kubernetes.ingress
+import org.apache.streampark.common.conf.{InternalConfigHolder, K8sFlinkConfig}
import org.apache.streampark.common.util.ImplicitsUtils._
import io.fabric8.kubernetes.api.model.networking.v1.IngressBuilder
@@ -60,6 +61,7 @@ class IngressStrategyV1 extends IngressStrategy {
.addToOwnerReferences(ownerReference) // Add OwnerReference
.endMetadata()
.withNewSpec()
+
.withIngressClassName(InternalConfigHolder.get[String](K8sFlinkConfig.ingressClass))
.addNewRule()
.withHost(domainName)
.withNewHttp()
diff --git
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala
index 332f857dd..c49a2b4f1 100644
---
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala
+++
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala
@@ -17,6 +17,7 @@
package org.apache.streampark.flink.kubernetes.ingress
+import org.apache.streampark.common.conf.{InternalConfigHolder, K8sFlinkConfig}
import org.apache.streampark.common.util.ImplicitsUtils._
import io.fabric8.kubernetes.api.model.IntOrString
@@ -61,6 +62,7 @@ class IngressStrategyV1beta1 extends IngressStrategy {
.addToOwnerReferences(ownerReference)
.endMetadata()
.withNewSpec()
+
.withIngressClassName(InternalConfigHolder.get[String](K8sFlinkConfig.ingressClass))
.addNewRule()
.withHost(domainName)
.withNewHttp()
