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

Fix ignoring error when loading segment (#23830) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/23858/head
yihao.dai 2023-05-04 15:10:39 +08:00 committed by GitHub
parent a76e9d20ec
commit 02734d9eb0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/querynodev2/segments/segment_loader.go
View File

@ -243,9 +243,7 @@ func (loader *segmentLoader) Load(ctx context.Context,
if len(loaded) != len(newSegments) {
// Free the memory of segments which failed to load
for _, segment := range newSegments {
if !loadedSegments.Contain(segment) {
DeleteSegment(segment)
}
DeleteSegment(segment)
}
debug.FreeOSMemory()
@ -255,7 +253,7 @@ func (loader *segmentLoader) Load(ctx context.Context,
log.Info("partial segments are loaded", zap.Int64s("loadedSegments", loadedIDs))
}
return lo.Map(loaded, func(segment *LocalSegment, _ int) Segment { return segment }), nil
return lo.Map(loaded, func(segment *LocalSegment, _ int) Segment { return segment }), err
}
func (loader *segmentLoader) LoadBloomFilterSet(ctx context.Context, collectionID int64, version int64, infos ...*querypb.SegmentLoadInfo) ([]*pkoracle.BloomFilterSet, error) {