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);