fix

Author: qianye1001

store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java

@@ -515,6 +515,9 @@ private void compensateForHA(ConcurrentMap<String, Long> cqOffsetTable) {
         }
     }
 
+    /**
+     * @param loadAfterDestroy file version cq do not need reload, so ignore
+     */
     @Override
     public void destroy(boolean loadAfterDestroy) {
         for (ConcurrentMap<Integer, ConsumeQueueInterface> maps : this.consumeQueueTable.values()) {

store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java

@@ -49,6 +49,11 @@ public RocksDBConsumeQueue(final MessageStoreConfig messageStoreConfig,
         this.queueId = queueId;
     }
 
+    /**
+     * Only used to pass parameters when calling the destroy method
+     *
+     * @see RocksDBConsumeQueueStore#destroy(ConsumeQueueInterface)
+     */
     public RocksDBConsumeQueue(final String topic, final int queueId) {
         this(null, null, topic, queueId);
     }

store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java

@@ -574,14 +574,14 @@ public String getServiceName() {
         }
 
         protected void deleteExpiredFiles() {
-
             long minOffset = messageStore.getCommitLog().getMinOffset();
             if (minOffset > this.lastPhysicalMinOffset) {
                 this.lastPhysicalMinOffset = minOffset;
 
                 boolean spaceFull = isSpaceToDelete();
                 boolean timeUp = messageStore.isTimeToDelete();
                 if (spaceFull || timeUp) {
+                    // To delete the CQ Units whose physical offset is smaller min physical offset in commitLog.
                     cleanExpired(minOffset);
                 }
 
@@ -596,8 +596,8 @@ private boolean isSpaceToDelete() {
                 .getStorePathConsumeQueue(messageStoreConfig.getStorePathRootDir());
             double logicsRatio = UtilAll.getDiskPartitionSpaceUsedPercent(storePathLogics);
             if (logicsRatio > diskSpaceWarningLevelRatio) {
-                boolean diskOk = messageStore.getRunningFlags().getAndMakeLogicDiskFull();
-                if (diskOk) {
+                boolean diskMaybeFull = messageStore.getRunningFlags().getAndMakeLogicDiskFull();
+                if (diskMaybeFull) {
                     log.error("logics disk maybe full soon " + logicsRatio + ", so mark disk full");
                 }
             } else if (logicsRatio > diskSpaceCleanForciblyRatio) {