admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-28 22:45:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

Change retention ticker time to 10 minutes (#9933)

Browse Source 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-10-15 15:44:35 +08:00 committed by GitHub
parent 2a1c679c5c
commit 2cfdf22897
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
View File

@ -33,15 +33,15 @@ var RocksmqRetentionTimeInMinutes int64
// RocksmqRetentionSizeInMB is the size of retention
var RocksmqRetentionSizeInMB int64
// TickerTimeInSeconds is the time of expired check
var TickerTimeInSeconds int64 = 6
// Const value that used to convert unit
const (
MB = 2 << 20
MINUTE = 60
)
// TickerTimeInSeconds is the time of expired check, default 10 minutes
var TickerTimeInSeconds int64 = 10 * MINUTE
type topicPageInfo struct {
pageEndID []UniqueID
pageMsgSize map[UniqueID]int64

1
internal/util/rocksmq/server/rocksmq/rocksmq_retention_test.go
View File

@ -34,6 +34,7 @@ func TestMain(m *testing.M) {
log.Error("MkdirALl error for path", zap.Any("path", retentionPath))
return
}
atomic.StoreInt64(&TickerTimeInSeconds, 6)
code := m.Run()
os.Exit(code)
}