From e7050a9cefed0bec636c83ea292eed771d14d18f Mon Sep 17 00:00:00 2001 From: Gao Date: Wed, 26 Mar 2025 12:00:19 +0800 Subject: [PATCH] fix: correct WithGroupSize while reducing (#40888) issue: https://github.com/milvus-io/milvus/issues/40887 Signed-off-by: chasingegg --- internal/querynodev2/handlers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/querynodev2/handlers.go b/internal/querynodev2/handlers.go index d182ecb84e..e4cd3aa35a 100644 --- a/internal/querynodev2/handlers.go +++ b/internal/querynodev2/handlers.go @@ -393,7 +393,7 @@ func (node *QueryNode) searchChannel(ctx context.Context, req *querypb.SearchReq resp, err := segments.ReduceSearchOnQueryNode(ctx, results, reduce.NewReduceSearchResultInfo(req.GetReq().GetNq(), req.GetReq().GetTopk()).WithMetricType(req.GetReq().GetMetricType()).WithGroupByField(req.GetReq().GetGroupByFieldId()). - WithGroupSize(req.GetReq().GetGroupByFieldId()).WithAdvance(req.GetReq().GetIsAdvanced())) + WithGroupSize(req.GetReq().GetGroupSize()).WithAdvance(req.GetReq().GetIsAdvanced())) if err != nil { return nil, err }