From ef4df1bda31bfd7d7085a06f1ee696a20f217894 Mon Sep 17 00:00:00 2001 From: benjobs Date: Sat, 21 Sep 2024 01:06:40 +0800 Subject: [PATCH] [Improve] application.setFlinkClusterId minor improvement --- .../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 a15aefaee2..6ed4df915a 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 boolean update(Application appParam) { 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());