Browse Source

fix this issue (#7683)

3.0.0/version-upgrade
calvin 3 years ago committed by GitHub
parent
commit
6b5db0ac5b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 4
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskGroupServiceImpl.java
  2. 2
      dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

4
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskGroupServiceImpl.java

@ -88,6 +88,9 @@ public class TaskGroupServiceImpl extends BaseServiceImpl implements TaskGroupSe
} }
TaskGroup taskGroup = new TaskGroup(name, projectcode, description, TaskGroup taskGroup = new TaskGroup(name, projectcode, description,
groupSize, loginUser.getId(), Flag.YES.getCode()); groupSize, loginUser.getId(), Flag.YES.getCode());
taskGroup.setCreateTime(new Date());
taskGroup.setUpdateTime(new Date());
if (taskGroupMapper.insert(taskGroup) > 0) { if (taskGroupMapper.insert(taskGroup) > 0) {
putMsg(result, Status.SUCCESS); putMsg(result, Status.SUCCESS);
} else { } else {
@ -120,6 +123,7 @@ public class TaskGroupServiceImpl extends BaseServiceImpl implements TaskGroupSe
} }
taskGroup.setGroupSize(groupSize); taskGroup.setGroupSize(groupSize);
taskGroup.setDescription(description); taskGroup.setDescription(description);
taskGroup.setUpdateTime(new Date());
if (StringUtils.isNotEmpty(name)) { if (StringUtils.isNotEmpty(name)) {
taskGroup.setName(name); taskGroup.setName(name);
} }

2
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

@ -2691,6 +2691,8 @@ public class ProcessService {
String taskName, Integer groupId, String taskName, Integer groupId,
Integer processId, Integer priority, TaskGroupQueueStatus status) { Integer processId, Integer priority, TaskGroupQueueStatus status) {
TaskGroupQueue taskGroupQueue = new TaskGroupQueue(taskId, taskName, groupId, processId, priority, status); TaskGroupQueue taskGroupQueue = new TaskGroupQueue(taskId, taskName, groupId, processId, priority, status);
taskGroupQueue.setCreateTime(new Date());
taskGroupQueue.setUpdateTime(new Date());
taskGroupQueueMapper.insert(taskGroupQueue); taskGroupQueueMapper.insert(taskGroupQueue);
return taskGroupQueue; return taskGroupQueue;
} }

Loading…
Cancel
Save