From 12d36760b8c0037289ef281f1ea8ab0faf3057f4 Mon Sep 17 00:00:00 2001
From: ligang <ligang@analysys.com.cn>
Date: Tue, 21 May 2019 15:37:31 +0800
Subject: [PATCH] add checkExists in deleteJob

---
 .../java/cn/escheduler/api/quartz/QuartzExecutors.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/escheduler-api/src/main/java/cn/escheduler/api/quartz/QuartzExecutors.java b/escheduler-api/src/main/java/cn/escheduler/api/quartz/QuartzExecutors.java
index 92e351d5c..5cb3b3385 100644
--- a/escheduler-api/src/main/java/cn/escheduler/api/quartz/QuartzExecutors.java
+++ b/escheduler-api/src/main/java/cn/escheduler/api/quartz/QuartzExecutors.java
@@ -26,8 +26,8 @@ import org.quartz.impl.matchers.GroupMatcher;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.Calendar;
 import java.util.*;
+import java.util.Calendar;
 import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
@@ -226,8 +226,12 @@ public class QuartzExecutors {
   public boolean deleteJob(String jobName, String jobGroupName) {
     lock.writeLock().lock();
     try {
-      logger.info("try to delete job, job name: {}, job group name: {},", jobName, jobGroupName);
-      return scheduler.deleteJob(new JobKey(jobName, jobGroupName));
+      JobKey jobKey = new JobKey(jobName,jobGroupName);
+      if(scheduler.checkExists(jobKey)){
+        logger.info("try to delete job, job name: {}, job group name: {},", jobName, jobGroupName);
+        return scheduler.deleteJob(jobKey);
+      }
+
     } catch (SchedulerException e) {
       logger.error(String.format("delete job : %s failed",jobName), e);
     } finally {
-- 
GitLab