(incubator-streampark) branch dev updated: improve cluster connection check (#3464)

[cancai]

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

cancai 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 6b9214f3a improve cluster connection check (#3464)
6b9214f3a is described below

commit 6b9214f3a529e3a79a4313ea7d8044e2762e49ba
Author: zhengke zhou <36791902+zz...@users.noreply.github.com>
AuthorDate: Sat Jan 13 22:47:10 2024 +0800

    improve cluster connection check (#3464)
---
 .../streampark/console/core/service/impl/FlinkClusterServiceImpl.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
index 9400da6d9..4e3875fee 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
@@ -123,6 +123,7 @@ public class FlinkClusterServiceImpl extends 
ServiceImpl<FlinkClusterMapper, Fli
 
     // 3) Check connection
     if (FlinkExecutionMode.isRemoteMode(cluster.getFlinkExecutionModeEnum())
+        && cluster.getClusterId() != null
         && !flinkClusterWatcher.verifyClusterConnection(cluster)) {
       result.setMsg("The remote cluster connection failed, please check!");
       result.setStatus(3);