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 d7b866512 fix TLS cert bug (#3001)
d7b866512 is described below
commit d7b866512f5739b58b2165ebfe2f97ac99807021
Author: blackCat <[email protected]>
AuthorDate: Wed Aug 30 22:01:29 2023 +0800
fix TLS cert bug (#3001)
---
.../apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala | 2 +-
.../streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
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 8fb5711e6..c5c2fdd0b 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
@@ -40,7 +40,7 @@ class IngressStrategyV1 extends IngressStrategy {
Option(client.network.v1.ingresses.inNamespace(nameSpace).withName(clusterId).get)
.map(ingress => ingress.getSpec.getRules.get(0))
.map(rule => rule.getHost -> rule.getHttp.getPaths.get(0).getPath)
- .map { case (host, path) => s"https://$host$path"; }
+ .map { case (host, path) => s"http://$host$path"; }
.getOrElse(clusterClient.getWebInterfaceURL)
}.recover {
case e =>
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 97654796c..8cbc276e4 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
@@ -41,7 +41,7 @@ class IngressStrategyV1beta1 extends IngressStrategy {
Option(client.network.v1beta1.ingresses.inNamespace(nameSpace).withName(clusterId).get)
.map(ingress => ingress.getSpec.getRules.get(0))
.map(rule => rule.getHost -> rule.getHttp.getPaths.get(0).getPath)
- .map { case (host, path) => s"https://$host$path"; }
+ .map { case (host, path) => s"http://$host$path"; }
.getOrElse(clusterClient.getWebInterfaceURL)
}.recover {
case e =>
