[ISSUE #6904] Fix fail to start broker if mapped file size is 0 (#6903)

apache · Jun 22, 2023 · 4e09a9c · 4e09a9c
1 parent 1f0cdc8
commit 4e09a9c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java b/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
@@ -247,11 +247,18 @@ public boolean doLoad(List<File> files) {
         // ascending order
         files.sort(Comparator.comparing(File::getName));
 
-        for (File file : files) {
+        for (int i = 0; i < files.size(); i++) {
+            File file = files.get(i);
             if (file.isDirectory()) {
                 continue;
             }
 
+            if (file.length() == 0 && i == files.size() - 1) {
+                boolean ok = file.delete();
+                log.warn("{} size is 0, auto delete. is_ok: {}", file, ok);
+                continue;
+            }
+
             if (file.length() != this.mappedFileSize) {
                 log.warn(file + "\t" + file.length()
                         + " length not matched message store config value, please check it manually");