From 7094722fb046cfd2a72d3f15d1c7c29e0fa35b6d Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 29 Sep 2021 20:54:00 +0800 Subject: [PATCH] Normalize rocksmq comment (#8886) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_retention.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()