diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
index 1ab8239711..628494609b 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
@@ -312,15 +312,6 @@ func (ri *retentionInfo) retention() error {
 				}
 			}
 			ri.mutex.RUnlock()
-			// ri.lastRetentionTime.Range(func(k, v interface{}) bool {
-			// 	if v.(int64)+checkTime < timeNow {
-			// 		err := ri.newExpiredCleanUp(k.(string))
-			// 		if err != nil {
-			// 			log.Warn("Retention expired clean failed", zap.Any("error", err))
-			// 		}
-			// 	}
-			// 	return true
-			// })
 		}
 	}
 }