diff --git a/internal/proxynode/task.go b/internal/proxynode/task.go index 3d11536de0..7b85eb0307 100644 --- a/internal/proxynode/task.go +++ b/internal/proxynode/task.go @@ -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 }