diff --git a/internal/querycoordv2/job/job_release.go b/internal/querycoordv2/job/job_release.go index 3ffccecd7bfae..61c95284835fd 100644 --- a/internal/querycoordv2/job/job_release.go +++ b/internal/querycoordv2/job/job_release.go @@ -80,11 +80,6 @@ func (job *ReleaseCollectionJob) Execute() error { return nil } - loadedPartitions := job.meta.CollectionManager.GetPartitionsByCollection(job.ctx, req.GetCollectionID()) - toRelease := lo.Map(loadedPartitions, func(partition *meta.Partition, _ int) int64 { - return partition.GetPartitionID() - }) - err := job.meta.CollectionManager.RemoveCollection(job.ctx, req.GetCollectionID()) if err != nil { msg := "failed to remove collection"