test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-03 04:19:18 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

Break page loop when no acked ts is nil (#12705)

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

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

@ -171,6 +171,9 @@ func (ri *retentionInfo) expiredCleanUp(topic string) error {
if err != nil {
return err
}
if ackedTsVal == "" {
break
}
ackedTs, err := strconv.ParseInt(ackedTsVal, 10, 64)
if err != nil {
return err