From 28575b20fd9190cef0c842d0ce3eaad8cda22cbf Mon Sep 17 00:00:00 2001 From: sunqinwen Date: Wed, 25 Nov 2020 14:41:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A0=E7=A7=92=E7=BA=A7?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=97=B6=E7=9A=84sql=E6=8A=A5=E9=94=99?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/service/timing/schedule/OmsScheduleService.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java index 2115a664..32dcaf77 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java @@ -220,6 +220,9 @@ public class OmsScheduleService { try { // 查询所有的秒级任务(只包含ID) List jobIds = jobInfoRepository.findByAppIdInAndStatusAndTimeExpressionTypeIn(partAppIds, SwitchableStatus.ENABLE.getV(), TimeExpressionType.frequentTypes); + if (CollectionUtils.isEmpty(jobIds)) { + return; + } // 查询日志记录表中是否存在相关的任务 List runningJobIdList = instanceInfoRepository.findByJobIdInAndStatusIn(jobIds, InstanceStatus.generalizedRunningStatus); Set runningJobIdSet = Sets.newHashSet(runningJobIdList);