diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go index 53912a39cadc9319a9bb5da24233b079e8dcacbc..b22e237527c27a42a3b27655914359f6384ed872 100644 --- a/internal/proxy/impl.go +++ b/internal/proxy/impl.go @@ -2162,6 +2162,11 @@ func (node *Proxy) GetQuerySegmentInfo(ctx context.Context, req *milvuspb.GetQue resp.Status.Reason = err.Error() 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{ Base: &commonpb.MsgBase{ MsgType: commonpb.MsgType_SegmentInfo, @@ -2169,7 +2174,8 @@ func (node *Proxy) GetQuerySegmentInfo(ctx context.Context, req *milvuspb.GetQue Timestamp: 0, SourceID: Params.ProxyID, }, - SegmentIDs: segments, + CollectionID: collID, + SegmentIDs: segments, }) if err != nil { log.Error("Failed to get segment info from QueryCoord",