From 09199170a424a1294d3408853790bfa4543ff18a Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 3 Aug 2021 21:47:24 +0800 Subject: [PATCH] sync call querycoord releaseXXXX (#6978) Signed-off-by: xige-16 --- internal/rootcoord/task.go | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/internal/rootcoord/task.go b/internal/rootcoord/task.go index b70ded0588..28164ab0f2 100644 --- a/internal/rootcoord/task.go +++ b/internal/rootcoord/task.go @@ -253,11 +253,10 @@ func (t *DropCollectionReqTask) Execute(ctx context.Context) error { t.core.dmlChannels.RemoveProducerChannels(collMeta.PhysicalChannelNames...) //notify query service to release collection - go func() { - if err = t.core.CallReleaseCollectionService(t.core.ctx, ts, 0, collMeta.ID); err != nil { - log.Warn("CallReleaseCollectionService failed", zap.String("error", err.Error())) - } - }() + if err = t.core.CallReleaseCollectionService(t.core.ctx, ts, 0, collMeta.ID); err != nil { + log.Error("CallReleaseCollectionService failed", zap.String("error", err.Error())) + return err + } req := proxypb.InvalidateCollMetaCacheRequest{ Base: &commonpb.MsgBase{ @@ -509,11 +508,10 @@ func (t *DropPartitionReqTask) Execute(ctx context.Context) error { t.core.proxyClientManager.InvalidateCollectionMetaCache(ctx, &req) //notify query service to release partition - go func() { - if err = t.core.CallReleasePartitionService(t.core.ctx, ts, 0, collInfo.ID, []typeutil.UniqueID{partID}); err != nil { - log.Warn("CallReleaseCollectionService failed", zap.String("error", err.Error())) - } - }() + if err = t.core.CallReleasePartitionService(t.core.ctx, ts, 0, collInfo.ID, []typeutil.UniqueID{partID}); err != nil { + log.Error("CallReleaseCollectionService failed", zap.String("error", err.Error())) + return err + } // Update DDOperation in etcd return t.core.setDdMsgSendFlag(true)