From d8b7c53c8fdd801b52fccbfc851aa4fecd7aee13 Mon Sep 17 00:00:00 2001 From: dhb52 Date: Fri, 22 Nov 2024 17:10:29 +0800 Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.3.0-beta1):=20=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E5=88=86=E9=A1=B5=E5=88=A0=E9=99=A4=EF=BC=8C=E5=8F=AAselect=20?= =?UTF-8?q?id=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/task/support/schedule/JobClearLogSchedule.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java index 14399ecd..0e7bdc3c 100644 --- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java +++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java @@ -120,7 +120,9 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { Lists.partition(ids, 500).forEach(jobTaskBatchMapper::deleteByIds); // Waiting for deletion JobTaskList - List jobTaskList = jobTaskMapper.selectList(new LambdaQueryWrapper().in(JobTask::getTaskBatchId, ids)); + List jobTaskList = jobTaskMapper.selectList(new LambdaQueryWrapper() + .select(JobTask::getId) + .in(JobTask::getTaskBatchId, ids)); if (CollectionUtils.isEmpty(jobTaskList)) { return; } @@ -128,7 +130,9 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { Lists.partition(jobTaskListIds, 500).forEach(jobTaskMapper::deleteByIds); // Waiting for deletion JobLogMessageList - List jobLogMessageList = jobLogMessageMapper.selectList(new LambdaQueryWrapper().in(JobLogMessage::getTaskBatchId, ids)); + List jobLogMessageList = jobLogMessageMapper.selectList(new LambdaQueryWrapper() + .select(JobLogMessage::getId) + .in(JobLogMessage::getTaskBatchId, ids)); if (CollectionUtils.isEmpty(jobLogMessageList)) { return; }