[Fix]: User-defined ingress causes job status error (apache#3792) (ap…

…ache#4047) * [Fix]: User-defined ingress causes job status error (apache#3792) * [Fix]: User-defined ingress causes job status error * Update IngressStrategyV1.scala --------- Co-authored-by: unknown <[email protected]> Co-authored-by: benjobs <[email protected]>
xiaows08 · Sep 9, 2024 · fd116a1 · fd116a1
1 parent c3c468c
commit fd116a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...tes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala b/...tes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
@@ -45,7 +45,7 @@ class IngressStrategyV1 extends IngressStrategy {
             Option(ingress)
               .map(ingress => ingress.getSpec.getRules.head)
               .map(rule => rule.getHost -> rule.getHttp.getPaths.head.getPath)
-              .map { case (host, path) => s"http://$host$path" }
+              .map { case (host, path) => s"http://$host${path.replaceAll("\\/$", "")}" }
               .getOrElse {
                 Utils.using(clusterClient)(client => client.getWebInterfaceURL)
               }