(incubator-streampark) branch dev-2.1.3 updated: bugfix: if its not session model,ClusterId should null,not use jobName as ClusterId (#3587)

[benjobs]

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

benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 30cce1f52 bugfix: if its not session model,ClusterId should null,not 
use jobName as ClusterId (#3587)
30cce1f52 is described below

commit 30cce1f52cdbdc7c69b023b72d6e2d0099ba0864
Author: sunshine <13574...@qq.com>
AuthorDate: Wed Feb 28 13:17:53 2024 +0800

    bugfix: if its not session model,ClusterId should null,not use jobName as 
ClusterId (#3587)
---
 .../streampark/console/core/service/impl/ApplicationServiceImpl.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index b2ce49006..384bbd292 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -851,9 +851,7 @@ public class ApplicationServiceImpl extends 
ServiceImpl<ApplicationMapper, Appli
 
     newApp.setJobName(jobName);
     newApp.setClusterId(
-        ExecutionMode.isSessionMode(oldApp.getExecutionModeEnum())
-            ? oldApp.getClusterId()
-            : jobName);
+        ExecutionMode.isSessionMode(oldApp.getExecutionModeEnum()) ? 
oldApp.getClusterId() : null);
     newApp.setArgs(appParam.getArgs() != null ? appParam.getArgs() : 
oldApp.getArgs());
     newApp.setVersionId(oldApp.getVersionId());