milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix DropCollection task in Proxy 

Signed-off-by: dragondriver <jiquan.long@zilliz.com>
pull/4973/head^2
dragondriver 2021-02-07 09:56:39 +08:00 committed by yefu.chen
parent cdcf006690
commit 8f4995dab5
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/proxynode/task.go
View File

@ -397,14 +397,17 @@ func (dct *DropCollectionTask) Execute() error {
if err != nil {
return err
}
dct.result, _ = dct.masterClient.DropCollection(dct.DropCollectionRequest)
if dct.result.ErrorCode != commonpb.ErrorCode_SUCCESS {
return errors.New(dct.result.Reason)
dct.result, err = dct.masterClient.DropCollection(dct.DropCollectionRequest)
if err != nil {
return err
}
err = globalInsertChannelsMap.closeInsertMsgStream(collID)
if err != nil {
return err
}
return nil
}