From 05a966afbe96d02439df074c8ed9636e9065f37e Mon Sep 17 00:00:00 2001 From: xige-16 Date: Mon, 31 Oct 2022 17:17:34 +0800 Subject: [PATCH] Delete row num check before load (#20205) Signed-off-by: xige-16 Signed-off-by: xige-16 --- internal/querynode/segment_loader.go | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/internal/querynode/segment_loader.go b/internal/querynode/segment_loader.go index 18e514192e..8b22104aae 100644 --- a/internal/querynode/segment_loader.go +++ b/internal/querynode/segment_loader.go @@ -251,18 +251,6 @@ func (loader *segmentLoader) loadFiles(ctx context.Context, segment *Segment, fieldID := fieldBinlog.FieldID // check num rows of data meta and index meta are consistent 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{ fieldBinlog: fieldBinlog, indexInfo: indexInfo,