提交 eba5b9ae 编写于 作者: S sunby 提交者: yefu.chen

Fix queryservice client init bug

Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
上级 b07b2484
......@@ -39,7 +39,7 @@ func (c *Client) Init() error {
var err error
for i := 0; i < c.retry; i++ {
if c.conn, err = grpc.DialContext(ctx, c.addr, grpc.WithInsecure(), grpc.WithBlock()); err != nil {
if c.conn, err = grpc.DialContext(ctx, c.addr, grpc.WithInsecure(), grpc.WithBlock()); err == nil {
break
}
}
......
......@@ -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
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册