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; }