admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix rocksmq retention test is not stable (#21925) (#25115)

Browse Source 
Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
This commit is contained in:
aoiasd 2023-07-11 18:40:29 +08:00 committed by GitHub
parent 75ed8d4702
commit 66ea847cb8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/mq/mqimpl/rocksmq/server/rocksmq_retention_test.go
View File

@ -540,15 +540,15 @@ func TestRmqRetention_PageTimeExpire(t *testing.T) {
assert.Equal(t, len(cMsgs), msgNum)
assert.Equal(t, cMsgs[0].MsgID, ids2[0])
time.Sleep(time.Duration(3) * time.Second)
err = rmq.ForceSeek(topicName, groupName, ids[10])
assert.Nil(t, err)
newRes, err := rmq.Consume(topicName, groupName, 1)
assert.Nil(t, err)
assert.Equal(t, len(newRes), 1)
// point to first not consumed messages
assert.Equal(t, newRes[0].MsgID, ids2[0])
assert.Eventually(t, func() bool {
err = rmq.ForceSeek(topicName, groupName, ids[0])
assert.Nil(t, err)
newRes, err := rmq.Consume(topicName, groupName, 1)
assert.Nil(t, err)
assert.Equal(t, len(newRes), 1)
// point to first not consumed messages
return newRes[0].MsgID == ids2[0]
}, 5*time.Second, 1*time.Second)
// test acked size acked ts and other meta are updated as expect
msgSizeKey := MessageSizeTitle + topicName