Merge pull request apache#2018 from imaffe/affe-0520-fix-slotvalue

[ISSUE apache#1807] only increase hashSlotCount when using slot for the first time
newstarjones · May 25, 2020 · a8f7730 · a8f7730
2 parents b54681c + a14cf63
commit a8f7730
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -134,7 +134,9 @@ public boolean putKey(final String key, final long phyOffset, final long storeTi
                     this.indexHeader.setBeginTimestamp(storeTimestamp);
                 }
 
-                this.indexHeader.incHashSlotCount();
+                if (invalidIndex == slotValue) {
+                    this.indexHeader.incHashSlotCount();
+                }
                 this.indexHeader.incIndexCount();
                 this.indexHeader.setEndPhyOffset(phyOffset);
                 this.indexHeader.setEndTimestamp(storeTimestamp);