[dolphinscheduler] branch dev updated: [Fix-5886][server] Enhanced scheduler delete check (#5936)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs 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 1401c2e  [Fix-5886][server] Enhanced scheduler delete check (#5936)
1401c2e is described below

commit 1401c2e5f77d65ec2e39ae8f04dc8a8f306683bd
Author: Squidyu <1297554...@qq.com>
AuthorDate: Tue Aug 3 12:30:36 2021 +0800

    [Fix-5886][server] Enhanced scheduler delete check (#5936)
    
    * Add:Name verification remove the first and last spaces.
    
    * Update: wrong word: 'WAITTING' ->'WAITING'
    
    * Add: Strengthen verification
    
    Co-authored-by: Squid <2824638...@qq.com>
---
 .../apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java
 
b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java
index 2921ce2..762316e 100644
--- 
a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java
+++ 
b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java
@@ -75,8 +75,8 @@ public class ProcessScheduleJob implements Job {
 
         // query schedule
         Schedule schedule = getProcessService().querySchedule(scheduleId);
-        if (schedule == null) {
-            logger.warn("process schedule does not exist in db，delete schedule 
job in quartz, projectId:{}, scheduleId:{}", projectId, scheduleId);
+        if (schedule == null || ReleaseState.OFFLINE == 
schedule.getReleaseState()) {
+            logger.warn("process schedule does not exist in db or process 
schedule offline，delete schedule job in quartz, projectId:{}, scheduleId:{}", 
projectId, scheduleId);
             deleteJob(projectId, scheduleId);
             return;
         }