diff --git a/internal/metastore/kv/datacoord/kv_catalog.go b/internal/metastore/kv/datacoord/kv_catalog.go index 0362446269..c5ec511794 100644 --- a/internal/metastore/kv/datacoord/kv_catalog.go +++ b/internal/metastore/kv/datacoord/kv_catalog.go @@ -169,7 +169,10 @@ 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()} + newSeg := &datapb.SegmentInfo{ + ID: newSegment.GetID(), + IsFake: newSegment.GetNumOfRows() == 0, + } segBytes, err := marshalSegmentInfo(newSeg) if err != nil { return err