diff --git a/internal/querynode/task.go b/internal/querynode/task.go index 97d329ff52..d085cb3a03 100644 --- a/internal/querynode/task.go +++ b/internal/querynode/task.go @@ -400,7 +400,7 @@ func (r *releaseCollectionTask) Execute(ctx context.Context) error { collection.setReleaseTime(r.req.Base.Timestamp) const gracefulReleaseTime = 3 - go func() { + func() { // release synchronously errMsg := "release collection failed, collectionID = " + strconv.FormatInt(r.req.CollectionID, 10) + ", err = " time.Sleep(gracefulReleaseTime * time.Second)