diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
index 190e00bb..718473a9 100644
--- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
+++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
@@ -86,13 +86,13 @@ public class CleanerSchedule extends AbstractSchedule implements Lifecycle {
     protected void doExecute() {
         try {
             // 清除日志默认保存天数大于零、最少保留最近一天的日志数据
-//            if (systemProperties.getLogStorage() <= 1) {
-//                SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
-//                return;
-//            }
+            if (systemProperties.getLogStorage() <= 1) {
+                SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
+                return;
+            }
 
             // clean retry log
-            LocalDateTime endTime = LocalDateTime.now();
+            LocalDateTime endTime = LocalDateTime.now().minusDays(systemProperties.getLogStorage());
             long total = PartitionTaskUtils.process(startId -> retryTaskBatchList(startId, endTime),
                     this::processRetryLogPartitionTasks, 0);