milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: [skip e2e]unstable l0 it (#35613) 

See also: #35617 
pr: #35612

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/35715/head
XuanYang-cn 2024-08-26 18:53:04 +08:00 committed by GitHub
parent 7062e6fcbf
commit ff68eb53d7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 45 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
tests/integration/levelzero/delete_on_growing_test.go
View File

@ -138,6 +138,18 @@ func (s *LevelZeroSuite) TestDeleteOnGrowing() {
s.generateSegment(collectionName, 2, 1, true)
s.generateSegment(collectionName, 2, 3, false)
checkRowCount := func(rowCount int) {
// query
queryResult, err := c.Proxy.Query(ctx, &milvuspb.QueryRequest{
CollectionName: collectionName,
OutputFields: []string{"count(*)"},
})
err = merr.CheckRPCCall(queryResult, err)
s.NoError(err)
s.EqualValues(rowCount, queryResult.GetFieldsData()[0].GetScalars().GetLongData().GetData()[0])
}
checkRowCount(5)
// delete
deleteResult, err := c.Proxy.Delete(ctx, &milvuspb.DeleteRequest{
CollectionName: collectionName,
@ -146,28 +158,43 @@ func (s *LevelZeroSuite) TestDeleteOnGrowing() {
err = merr.CheckRPCCall(deleteResult, err)
s.NoError(err)
checkFunc := func() {
// query
queryResult, err := c.Proxy.Query(ctx, &milvuspb.QueryRequest{
CollectionName: collectionName,
OutputFields: []string{"count(*)"},
})
err = merr.CheckRPCCall(queryResult, err)
s.NoError(err)
s.EqualValues(0, queryResult.GetFieldsData()[0].GetScalars().GetLongData().GetData()[0])
checkRowCount(0)
l0Exist := func() ([]*datapb.SegmentInfo, bool) {
segments, err := s.Cluster.MetaWatcher.ShowSegments()
s.Require().NoError(err)
s.Require().Greater(len(segments), 0)
for _, segment := range segments {
if segment.GetLevel() == datapb.SegmentLevel_L0 {
return segments, true
}
}
return nil, false
}
checkFunc()
segments, err := s.Cluster.MetaWatcher.ShowSegments()
s.Require().NoError(err)
s.EqualValues(3, len(segments))
for _, segment := range segments {
if segment.GetLevel() == datapb.SegmentLevel_L0 {
s.EqualValues(5, segment.Deltalogs[0].GetBinlogs()[0].GetEntriesNum())
checkL0Exist := func() {
failT := time.NewTimer(10 * time.Second)
checkT := time.NewTicker(100 * time.Millisecond)
for {
select {
case <-failT.C:
s.FailNow("L0 segment timeout")
case <-checkT.C:
if segments, exist := l0Exist(); exist {
failT.Stop()
for _, segment := range segments {
if segment.GetLevel() == datapb.SegmentLevel_L0 {
s.EqualValues(5, segment.Deltalogs[0].GetBinlogs()[0].GetEntriesNum())
}
}
return
}
}
}
}
checkL0Exist()
// release collection
status, err := c.Proxy.ReleaseCollection(ctx, &milvuspb.ReleaseCollectionRequest{CollectionName: collectionName})
err = merr.CheckRPCCall(status, err)
@ -181,7 +208,7 @@ func (s *LevelZeroSuite) TestDeleteOnGrowing() {
s.Require().NoError(err)
s.WaitForLoad(ctx, collectionName)
checkFunc()
checkRowCount(0)
// drop collection
status, err = c.Proxy.DropCollection(ctx, &milvuspb.DropCollectionRequest{