From d6f7fbf19f0cee328cfa5ee53b84c0cc34e03ddd Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Wed, 16 Jun 2021 15:31:57 +0800 Subject: [PATCH] release collection synchronously (#5798) Signed-off-by: bigsheeper --- internal/querynode/task.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)