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