This is an automated email from the ASF dual-hosted git repository. leonbao pushed a commit to branch 2.0.0-release in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 9a5b8edaf81cbf3b4e3d1a4f7f940c90f512b717 Author: zwZjut <[email protected]> AuthorDate: Tue Nov 16 10:16:52 2021 +0800 fix switchVersion error (#6783) (#6784) Co-authored-by: honghuo.zw <[email protected]> Co-authored-by: Kirs <[email protected]> --- .../api/service/impl/TaskDefinitionServiceImpl.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskDefinitionServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskDefinitionServiceImpl.java index deed94f..e203b9b 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskDefinitionServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskDefinitionServiceImpl.java @@ -282,10 +282,11 @@ public class TaskDefinitionServiceImpl extends BaseServiceImpl implements TaskDe putMsg(result, Status.TASK_DEFINE_NOT_EXIST, taskCode); return result; } - TaskDefinitionLog taskDefinitionLog = taskDefinitionLogMapper.queryByDefinitionCodeAndVersion(taskCode, version); - taskDefinitionLog.setUserId(loginUser.getId()); - taskDefinitionLog.setUpdateTime(new Date()); - int switchVersion = taskDefinitionMapper.updateById(taskDefinitionLog); + TaskDefinitionLog taskDefinitionUpdate = taskDefinitionLogMapper.queryByDefinitionCodeAndVersion(taskCode, version); + taskDefinitionUpdate.setUserId(loginUser.getId()); + taskDefinitionUpdate.setUpdateTime(new Date()); + taskDefinitionUpdate.setId(taskDefinition.getId()); + int switchVersion = taskDefinitionMapper.updateById(taskDefinitionUpdate); if (switchVersion > 0) { result.put(Constants.DATA_LIST, taskCode); putMsg(result, Status.SUCCESS);
