Fix rocksmq retention panic when delete by message size (#7393)

Signed-off-by: N fishpenguin <kun.yu@zilliz.com>

Fix rocksmq retention panic when delete by message size (#7393)
Signed-off-by: N fishpenguin <kun.yu@zilliz.com>
9e0b2cce · yukun · Xiangyu Wang · 1c88c8b0 · 9e0b2cce
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

internal/util/rocksmq/server/rocksmq/rocksmq_retention.go internal/util/rocksmq/server/rocksmq/rocksmq_retention.go +1 -1

未找到文件。
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
@@ -377,7 +377,7 @@ func (ri *retentionInfo) expiredCleanUp(topic string) error {
 	if pageInfo != nil {
 		// Judge expire by ackedSize
 		if msgSizeExpiredCheck(deletedAckedSize, ackedInfo.ackedSize) {
-			for _, pEndID := range pageInfo.pageEndID[pageRetentionOffset:0] {
+			for _, pEndID := range pageInfo.pageEndID[pageRetentionOffset:] {
 				curDeletedSize := deletedAckedSize + pageInfo.pageMsgSize[pEndID]
 				if msgSizeExpiredCheck(curDeletedSize, ackedInfo.ackedSize) {
 					endID = pEndID