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

Fix empty getQuerySegmentInfos results (#10667) 

Signed-off-by: xige-16 <xi.ge@zilliz.com>
pull/10689/head
xige-16 2021-10-26 19:26:43 +08:00 committed by GitHub
parent a06dab29d7
commit fe8bfc3788
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/proxy/impl.go
View File

@ -2162,6 +2162,11 @@ func (node *Proxy) GetQuerySegmentInfo(ctx context.Context, req *milvuspb.GetQue
resp.Status.Reason = err.Error() resp.Status.Reason = err.Error()
return resp, nil return resp, nil
} }
collID, err := globalMetaCache.GetCollectionID(ctx, req.CollectionName)
if err != nil {
resp.Status.Reason = err.Error()
return resp, nil
}
infoResp, err := node.queryCoord.GetSegmentInfo(ctx, &querypb.GetSegmentInfoRequest{ infoResp, err := node.queryCoord.GetSegmentInfo(ctx, &querypb.GetSegmentInfoRequest{
Base: &commonpb.MsgBase{ Base: &commonpb.MsgBase{
MsgType: commonpb.MsgType_SegmentInfo, MsgType: commonpb.MsgType_SegmentInfo,
@ -2169,7 +2174,8 @@ func (node *Proxy) GetQuerySegmentInfo(ctx context.Context, req *milvuspb.GetQue
Timestamp: 0, Timestamp: 0,
SourceID: Params.ProxyID, SourceID: Params.ProxyID,
}, },
SegmentIDs: segments, CollectionID: collID,
SegmentIDs: segments,
}) })
if err != nil { if err != nil {
log.Error("Failed to get segment info from QueryCoord", log.Error("Failed to get segment info from QueryCoord",