From 08c51342865418108448cf458c9d5369261ebe45 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 16 Apr 2021 17:37:50 +0800 Subject: [PATCH] Fix collection cannot be found when searching Signed-off-by: bigsheeper --- internal/querynode/impl.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index e33798ef0..2b054cb89 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -158,7 +158,7 @@ func (node *QueryNode) WatchDmChannels(ctx context.Context, in *queryPb.WatchDmC } log.Debug("watchDmChannelsTask Enqueue done", zap.Any("collectionID", in.CollectionID)) - go func() { + func() { err = dct.WaitToFinish() if err != nil { log.Error(err.Error()) @@ -194,7 +194,7 @@ func (node *QueryNode) LoadSegments(ctx context.Context, in *queryPb.LoadSegment } log.Debug("loadSegmentsTask Enqueue done", zap.Any("collectionID", in.CollectionID)) - go func() { + func() { err = dct.WaitToFinish() if err != nil { log.Error(err.Error()) @@ -230,7 +230,7 @@ func (node *QueryNode) ReleaseCollection(ctx context.Context, in *queryPb.Releas } log.Debug("releaseCollectionTask Enqueue done", zap.Any("collectionID", in.CollectionID)) - go func() { + func() { err = dct.WaitToFinish() if err != nil { log.Error(err.Error()) @@ -266,7 +266,7 @@ func (node *QueryNode) ReleasePartitions(ctx context.Context, in *queryPb.Releas } log.Debug("releasePartitionsTask Enqueue done", zap.Any("collectionID", in.CollectionID)) - go func() { + func() { err = dct.WaitToFinish() if err != nil { log.Error(err.Error()) -- GitLab