This is an automated email from the ASF dual-hosted git repository.
benjobs 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 02aaab9c5 [Bug]Fixed some job properties are not replicated bug When
copy a job (#1559)
02aaab9c5 is described below
commit 02aaab9c5e7d0165882fa877fdea0f8a75886eb2
Author: Gerry <[email protected]>
AuthorDate: Fri Sep 9 21:51:07 2022 +0800
[Bug]Fixed some job properties are not replicated bug When copy a job
(#1559)
---
.../streampark/console/core/service/impl/ApplicationServiceImpl.java | 3 ++-
1 file changed, 2 insertions(+), 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 300583a0f..65a4e6c9c 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
@@ -623,7 +623,7 @@ public class ApplicationServiceImpl extends
ServiceImpl<ApplicationMapper, Appli
newApp.setClusterId(oldApp.getExecutionModeEnum() ==
ExecutionMode.KUBERNETES_NATIVE_SESSION ? oldApp.getClusterId() : jobName);
args = args != null && !"".equals(args) ? args : oldApp.getArgs();
newApp.setArgs(args);
- newApp.setVersionId(100000L);
+ newApp.setVersionId(oldApp.getVersionId());
newApp.setFlinkClusterId(oldApp.getFlinkClusterId());
newApp.setRestartSize(oldApp.getRestartSize());
@@ -660,6 +660,7 @@ public class ApplicationServiceImpl extends
ServiceImpl<ApplicationMapper, Appli
newApp.setJar(oldApp.getJar());
newApp.setJarCheckSum(oldApp.getJarCheckSum());
+ newApp.setTags(oldApp.getTags());
boolean saved = save(newApp);
if (saved) {
