From 67d38d6cf1d5b8a3b343bcd7750ba0cbed7f2eae Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 13 Oct 2021 20:38:33 +0800 Subject: [PATCH] Fix retention datarace (#9828) 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 0ee7b84156..3eb1d15aad 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go @@ -277,7 +277,7 @@ func (ri *retentionInfo) loadRetentionInfo(topic string, wg *sync.WaitGroup) { func (ri *retentionInfo) retention() error { log.Debug("Rocksmq retention goroutine start!") // Do retention check every 6s - ticker := time.NewTicker(time.Duration(TickerTimeInSeconds * int64(time.Second))) + ticker := time.NewTicker(time.Duration(atomic.LoadInt64(&TickerTimeInSeconds) * int64(time.Second))) for { select {