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

Delete row num check before load (#20205)

Browse Source 
Signed-off-by: xige-16 <xi.ge@zilliz.com>

Signed-off-by: xige-16 <xi.ge@zilliz.com>
This commit is contained in:
xige-16 2022-10-31 17:17:34 +08:00 committed by GitHub
parent 37dce8a660
commit 05a966afbe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/querynode/segment_loader.go
View File

@ -251,18 +251,6 @@ func (loader *segmentLoader) loadFiles(ctx context.Context, segment *Segment,
fieldID := fieldBinlog.FieldID fieldID := fieldBinlog.FieldID
// check num rows of data meta and index meta are consistent // check num rows of data meta and index meta are consistent
if indexInfo, ok := fieldID2IndexInfo[fieldID]; ok { if indexInfo, ok := fieldID2IndexInfo[fieldID]; ok {
if loadInfo.GetNumOfRows() != indexInfo.GetNumRows() {
err = fmt.Errorf("num rows of segment binlog file %d mismatch with num rows of index file %d",
loadInfo.GetNumOfRows(), indexInfo.GetNumRows())
log.Error("load segment failed, set segment to meta failed",
zap.Int64("collectionID", segment.collectionID),
zap.Int64("partitionID", segment.partitionID),
zap.Int64("segmentID", segment.segmentID),
zap.Int64("indexBuildID", indexInfo.BuildID),
zap.Error(err))
return err
}
fieldInfo := &IndexedFieldInfo{ fieldInfo := &IndexedFieldInfo{
fieldBinlog: fieldBinlog, fieldBinlog: fieldBinlog,
indexInfo: indexInfo, indexInfo: indexInfo,