release collection synchronously (#5798)

Signed-off-by: N bigsheeper <yihao.dai@zilliz.com>

release collection synchronously (#5798)
Signed-off-by: N bigsheeper <yihao.dai@zilliz.com>
d6f7fbf1 · bigsheeper · GitHub · bf396444 · d6f7fbf1
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

internal/querynode/task.go internal/querynode/task.go +1 -1

未找到文件。
--- 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)