diff --git a/internal/rootcoord/meta_table.go b/internal/rootcoord/meta_table.go index 0fa5de0c45e8f..5fef29ef34246 100644 --- a/internal/rootcoord/meta_table.go +++ b/internal/rootcoord/meta_table.go @@ -456,7 +456,13 @@ func (mt *MetaTable) RemoveCollection(ctx context.Context, collectionID UniqueID ctx1 := contextutil.WithTenantID(ctx, Params.CommonCfg.ClusterName.GetValue()) aliases := mt.listAliasesByID(collectionID) - newColl := &model.Collection{CollectionID: collectionID, Aliases: aliases, DBID: coll.DBID} + newColl := &model.Collection{ + CollectionID: collectionID, + Partitions: model.ClonePartitions(coll.Partitions), + Fields: model.CloneFields(coll.Fields), + Aliases: aliases, + DBID: coll.DBID, + } if err := mt.catalog.DropCollection(ctx1, newColl, ts); err != nil { return err }