fix

Author: qianye1001

broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java

@@ -236,7 +236,7 @@ public boolean correctDelayOffset() {
         try {
             for (int delayLevel : delayLevelTable.keySet()) {
                 ConsumeQueueInterface cq =
-                    brokerController.getMessageStore().getQueueStore().findOrCreateConsumeQueue(TopicValidator.RMQ_SYS_SCHEDULE_TOPIC,
+                    brokerController.getMessageStore().findConsumeQueue(TopicValidator.RMQ_SYS_SCHEDULE_TOPIC,
                         delayLevel2QueueId(delayLevel));
                 Long currentDelayOffset = offsetTable.get(delayLevel);
                 if (currentDelayOffset == null || cq == null) {

store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java

@@ -2146,7 +2146,6 @@ public boolean isTimeToDelete() {
             DefaultMessageStore.LOGGER.info("it's time to reclaim disk space, " + when);
             return true;
         }
-
         return false;
     }