diff --git a/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java b/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java index 3d76b73dc282f421700f2a1164a2b6ef002363c5..e513edf1114eadeaea60c863ceeca17a6950f197 100644 --- 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);