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 11125d592..96325bdca 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
@@ -144,7 +144,7 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle {
             @Override
             protected void doInTransactionWithoutResult(final TransactionStatus status) {
 
-                idsPartition.forEach(jobTaskMapper::deleteByIds);
+                idsPartition.forEach(jobTaskBatchMapper::deleteByIds);
                 if (!CollectionUtils.isEmpty(jobTaskListIds)) {
                     Lists.partition(jobTaskListIds.stream().toList(), 500).forEach(jobTaskMapper::deleteByIds);
                 }