diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskGroupServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskGroupServiceImpl.java index b2354c28ad..28da3e1182 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskGroupServiceImpl.java +++ b/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, groupSize, loginUser.getId(), Flag.YES.getCode()); + + taskGroup.setCreateTime(new Date()); + taskGroup.setUpdateTime(new Date()); if (taskGroupMapper.insert(taskGroup) > 0) { putMsg(result, Status.SUCCESS); } else { @@ -120,6 +123,7 @@ public class TaskGroupServiceImpl extends BaseServiceImpl implements TaskGroupSe } taskGroup.setGroupSize(groupSize); taskGroup.setDescription(description); + taskGroup.setUpdateTime(new Date()); if (StringUtils.isNotEmpty(name)) { taskGroup.setName(name); } diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java index 342e91301f..5b590f06c6 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java @@ -2691,6 +2691,8 @@ public class ProcessService { String taskName, Integer groupId, Integer processId, Integer priority, TaskGroupQueueStatus status) { TaskGroupQueue taskGroupQueue = new TaskGroupQueue(taskId, taskName, groupId, processId, priority, status); + taskGroupQueue.setCreateTime(new Date()); + taskGroupQueue.setUpdateTime(new Date()); taskGroupQueueMapper.insert(taskGroupQueue); return taskGroupQueue; }