diff --git a/src/main/java/net/geedge/asw/module/runner/controller/JobController.java b/src/main/java/net/geedge/asw/module/runner/controller/JobController.java index 2e13f42..ee78da9 100644 --- a/src/main/java/net/geedge/asw/module/runner/controller/JobController.java +++ b/src/main/java/net/geedge/asw/module/runner/controller/JobController.java @@ -122,7 +122,7 @@ public class JobController { } if (job.getStatus().contains(RunnerConstant.JobStatus.PENDING.getValue())){ - jobQueueManager.requeueJob(job); + jobQueueManager.removeJob(job); } Thread runningThread = Constants.RUNNING_JOB_THREAD.get(id);