You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by mo...@apache.org on 2022/12/01 05:02:27 UTC
[incubator-streampark] 01/01: [bug]The specified args expire after the copy task
This is an automated email from the ASF dual-hosted git repository.
monster pushed a commit to branch args
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit c6bb4441f1593f5a6f21c7ba10ca249c9f1dd48b
Author: shihong90 <25...@qq.com>
AuthorDate: Thu Dec 1 13:02:15 2022 +0800
[bug]The specified args expire after the copy task
---
.../streampark/console/core/service/impl/ApplicationServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 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 b851f3cd7..41b1d43fd 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
@@ -717,7 +717,7 @@ public class ApplicationServiceImpl extends ServiceImpl<ApplicationMapper, Appli
newApp.setJobName(jobName);
newApp.setClusterId(ExecutionMode.isSessionMode(oldApp.getExecutionModeEnum()) ? oldApp.getClusterId() : jobName);
- newApp.setArgs(oldApp.getArgs());
+ newApp.setArgs((appParam.getArgs()) != null ? appParam.getArgs() : oldApp.getArgs());
newApp.setVersionId(oldApp.getVersionId());
newApp.setFlinkClusterId(oldApp.getFlinkClusterId());