From 482986cdf624a9c0c44a274762a14a97dd347b18 Mon Sep 17 00:00:00 2001 From: yah01 Date: Fri, 2 Dec 2022 11:41:16 +0800 Subject: [PATCH] Revert "Fix fake segment is never handled (#20935)" (#20945) This reverts commit 8f449f29960810bcebbcee84910e98ed8eaec42a. Signed-off-by: yah01 Signed-off-by: yah01 --- internal/metastore/kv/datacoord/kv_catalog.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/internal/metastore/kv/datacoord/kv_catalog.go b/internal/metastore/kv/datacoord/kv_catalog.go index c5ec511794..0362446269 100644 --- a/internal/metastore/kv/datacoord/kv_catalog.go +++ b/internal/metastore/kv/datacoord/kv_catalog.go @@ -169,10 +169,7 @@ func (kc *Catalog) AlterSegment(ctx context.Context, newSegment *datapb.SegmentI maps.Copy(kvs, segmentKvs) if newSegment.State == commonpb.SegmentState_Flushed && oldSegment.State != commonpb.SegmentState_Flushed { flushSegKey := buildFlushedSegmentPath(newSegment.GetCollectionID(), newSegment.GetPartitionID(), newSegment.GetID()) - newSeg := &datapb.SegmentInfo{ - ID: newSegment.GetID(), - IsFake: newSegment.GetNumOfRows() == 0, - } + newSeg := &datapb.SegmentInfo{ID: newSegment.GetID()} segBytes, err := marshalSegmentInfo(newSeg) if err != nil { return err