[ISSUE #7013] Polish ColdDataCheckService's logic (#7014)

* polish coldCtrl * remove the catch.
apache · Jul 11, 2023 · 1f0f3b2 · 1f0f3b2
1 parent b4496be
commit 1f0f3b2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -2089,6 +2089,11 @@ public void run() {
                     } else {
                         this.waitForRunning(defaultMessageStore.getMessageStoreConfig().getTimerColdDataCheckIntervalMs());
                     }
+
+                    if (pageSize < 0) {
+                        initPageSize();
+                    }
+
                     long beginClockTimestamp = this.systemClock.now();
                     scanFilesInPageCache();
                     long costTime = this.systemClock.now() - beginClockTimestamp;
@@ -2182,7 +2187,7 @@ private byte[] checkFileInPageCache(MappedFile mappedFile) {
         }
 
         private void initPageSize() {
-            if (pageSize < 0) {
+            if (pageSize < 0 && defaultMessageStore.getMessageStoreConfig().isColdDataFlowControlEnable()) {
                 try {
                     if (!MixAll.isWindows()) {
                         pageSize = LibC.INSTANCE.getpagesize();