This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.5
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
new ef4df1bda [Improve] application.setFlinkClusterId minor improvement
ef4df1bda is described below
commit ef4df1bda31bfd7d7085a06f1ee696a20f217894
Author: benjobs <[email protected]>
AuthorDate: Sat Sep 21 01:06:40 2024 +0800
[Improve] application.setFlinkClusterId minor improvement
---
.../streampark/console/core/service/impl/ApplicationServiceImpl.java | 1 -
1 file changed, 1 deletion(-)
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 a15aefaee..6ed4df915 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
@@ -993,7 +993,6 @@ public class ApplicationServiceImpl extends
ServiceImpl<ApplicationMapper, Appli
application.setDynamicProperties(appParam.getDynamicProperties());
application.setResolveOrder(appParam.getResolveOrder());
application.setExecutionMode(appParam.getExecutionMode());
- application.setFlinkClusterId(appParam.getFlinkClusterId());
application.setFlinkImage(appParam.getFlinkImage());
application.updateHotParams(appParam);
application.setK8sRestExposedType(appParam.getK8sRestExposedType());