You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by xi...@apache.org on 2023/07/13 08:21:15 UTC
[dolphinscheduler] branch dev updated: [FIX-14299][api]: check schedule exists (#14430)
This is an automated email from the ASF dual-hosted git repository.
xincheng 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 484f8419c4 [FIX-14299][api]: check schedule exists (#14430)
484f8419c4 is described below
commit 484f8419c4bd8d73fab7f4b3469dabf94269e077
Author: lutongzero <lu...@gmail.com>
AuthorDate: Thu Jul 13 16:21:07 2023 +0800
[FIX-14299][api]: check schedule exists (#14430)
* fix: check schedule exists
* put error message in result
---------
Co-authored-by: lutong <lu...@credithc.com>
---
.../dolphinscheduler/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();