From 484f8419c4bd8d73fab7f4b3469dabf94269e077 Mon Sep 17 00:00:00 2001 From: lutongzero Date: Thu, 13 Jul 2023 16:21:07 +0800 Subject: [PATCH] [FIX-14299][api]: check schedule exists (#14430) * fix: check schedule exists * put error message in result --------- Co-authored-by: lutong --- .../api/service/impl/SchedulerServiceImpl.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/SchedulerServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/SchedulerServiceImpl.java index 589d509ae0..6cf9fe2307 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/SchedulerServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/SchedulerServiceImpl.java @@ -167,6 +167,15 @@ public class SchedulerServiceImpl extends BaseServiceImpl implements SchedulerSe executorService.checkProcessDefinitionValid(projectCode, processDefinition, processDefineCode, processDefinition.getVersion()); + Schedule scheduleExists = + scheduleMapper.queryByProcessDefinitionCode(processDefineCode); + if (scheduleExists != null) { + log.error("Schedule already exist, scheduleId:{},processDefineCode:{}", scheduleExists.getId(), + processDefineCode); + putMsg(result, Status.SCHEDULE_ALREADY_EXISTS, processDefineCode, scheduleExists.getId()); + return result; + } + Schedule scheduleObj = new Schedule(); Date now = new Date();