diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
index 32d56263b5..0d9d2c2948 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
@@ -279,7 +279,7 @@ func (ri *retentionInfo) retention() error {
 	for {
 		select {
 		case <-ri.ctx.Done():
-			log.Debug("aaaaaaaaaaaaa")
+			log.Debug("Rocksmq retention finish!")
 			return nil
 		case t := <-ticker.C:
 			timeNow := t.Unix()