mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-06 17:18:35 +08:00
related: #45418 Signed-off-by: MrPresent-Han <chun.han@gmail.com> Co-authored-by: MrPresent-Han <chun.han@gmail.com>
This commit is contained in:
parent
e8bdc3f2a1
commit
87b466fd83
@ -514,6 +514,7 @@ func reduceResults(ctx context.Context, toReduceResults []*internalpb.SearchResu
|
||||
}
|
||||
|
||||
if len(validSearchResults) <= 0 {
|
||||
log.Debug("reduced search results is empty, fill in empty result")
|
||||
return fillInEmptyResult(nq), nil
|
||||
}
|
||||
|
||||
|
||||
@ -25,6 +25,7 @@ import (
|
||||
"strings"
|
||||
|
||||
"github.com/milvus-io/milvus-proto/go-api/v2/schemapb"
|
||||
"github.com/milvus-io/milvus/pkg/v2/log"
|
||||
"github.com/milvus-io/milvus/pkg/v2/util/merr"
|
||||
"github.com/milvus-io/milvus/pkg/v2/util/metric"
|
||||
"github.com/milvus-io/milvus/pkg/v2/util/typeutil"
|
||||
@ -516,7 +517,8 @@ func genIdGroupingMap(multipSearchResultData []*schemapb.SearchResultData) (map[
|
||||
idGroupValue := map[any]any{}
|
||||
for _, result := range multipSearchResultData {
|
||||
if result.GetGroupByFieldValue() == nil {
|
||||
return nil, fmt.Errorf("Group value is nil")
|
||||
log.Warn("Group value is nil, this is due to empty results in search reduce phase")
|
||||
continue
|
||||
}
|
||||
size := typeutil.GetSizeOfIDs(result.Ids)
|
||||
groupIter := typeutil.GetDataIterator(result.GetGroupByFieldValue())
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user