fix increase hashSlot value

a14cf634 · affe · 8ef01a6c · a14cf634
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java .../main/java/org/apache/rocketmq/store/index/IndexFile.java +3 -1

未找到文件。
--- a/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
+++ b/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
@@ -134,7 +134,9 @@ public class IndexFile {
                    this.indexHeader.setBeginTimestamp(storeTimestamp);
                }

-                this.indexHeader.incHashSlotCount();
+                if (invalidIndex == slotValue) {
+                    this.indexHeader.incHashSlotCount();
+                }
                this.indexHeader.incIndexCount();
                this.indexHeader.setEndPhyOffset(phyOffset);
                this.indexHeader.setEndTimestamp(storeTimestamp);