test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 11:29:48 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Fix queryservice connect error (#5526)

Browse Source 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
This commit is contained in:
godchen 2021-06-01 17:46:32 +08:00 committed by zhenshan.cao
parent fca3eb7126
commit 54ab03e28f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/distributed/queryservice/client/client.go
View File

@ -79,6 +79,8 @@ func (c *Client) Init() error {
log.Debug("QueryServiceClient try connect QueryService", zap.Any("c.addr", c.addr)) log.Debug("QueryServiceClient try connect QueryService", zap.Any("c.addr", c.addr))
if c.addr != "" { if c.addr != "" {
connectGrpcFunc := func() error { connectGrpcFunc := func() error {
ctx, cancel := context.WithTimeout(context.Background(), c.timeout)
defer cancel()
ctx, cancelFunc := context.WithTimeout(c.ctx, c.timeout) ctx, cancelFunc := context.WithTimeout(c.ctx, c.timeout)
defer cancelFunc() defer cancelFunc()
log.Debug("QueryServiceClient try connect ", zap.String("address", c.addr)) log.Debug("QueryServiceClient try connect ", zap.String("address", c.addr))