You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ca...@apache.org on 2022/01/15 15:52:11 UTC

[dolphinscheduler] branch dev updated: fix a few issues (#8063)

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

caishunfeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 5bcf7bc  fix a few issues (#8063)
5bcf7bc is described below

commit 5bcf7bcce6702dd4828215659c04cb487a70eff0
Author: calvin <ji...@163.com>
AuthorDate: Sat Jan 15 23:52:06 2022 +0800

    fix a few issues (#8063)
---
 .../api/service/impl/ProcessDefinitionServiceImpl.java                | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java
index 106533d..244441a 100644
--- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java
+++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java
@@ -602,6 +602,10 @@ public class ProcessDefinitionServiceImpl extends BaseServiceImpl implements Pro
         int insertVersion;
         if (processDefinition.equals(processDefinitionDeepCopy)) {
             insertVersion = processDefinitionDeepCopy.getVersion();
+            ProcessDefinitionLog processDefinitionLog = processDefinitionLogMapper.queryByDefinitionCodeAndVersion(processDefinition.getCode(), insertVersion);
+            processDefinitionLog.setOperator(loginUser.getId());
+            processDefinitionLog.setOperateTime(new Date());
+            int update = processDefinitionLogMapper.updateById(processDefinitionLog);
         } else {
             processDefinition.setUpdateTime(new Date());
             insertVersion = processService.saveProcessDefine(loginUser, processDefinition, Boolean.TRUE, Boolean.TRUE);