From 28909428fa83fd794daa7e55816dd6f17483cb39 Mon Sep 17 00:00:00 2001 From: zhangshuai Date: Thu, 28 Nov 2024 10:30:49 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8Djob=20=E5=8F=96?= =?UTF-8?q?=E6=B6=88=E5=90=8E=E6=9C=AA=E5=88=A0=E9=99=A4=E9=98=9F=E5=88=97?= =?UTF-8?q?=E4=B8=ADjob?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../net/geedge/asw/module/runner/controller/JobController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);