fix Can't open k8s session cluster webUI apache#2248 (apache#2441)

* fix Can't open k8s session cluster webUI apache#2248 * Update FlinkClusterServiceImpl.java
xiangboyuSmile · Mar 15, 2023 · 9fb0fb4 · 9fb0fb4
1 parent 08ee4f6
commit 9fb0fb4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java b/...rc/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
@@ -178,6 +178,8 @@ public void start(FlinkCluster cluster) {
           String address =
               YarnUtils.getRMWebAppURL() + "/proxy/" + deployResponse.clusterId() + "/";
           flinkCluster.setAddress(address);
+        } else {
+          flinkCluster.setAddress(deployResponse.address());
         }
         flinkCluster.setClusterId(deployResponse.clusterId());
         flinkCluster.setClusterState(ClusterState.STARTED.getValue());