From 5785756d31f11c772628e1ea2dda0ca2d0604e33 Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Mon, 16 Oct 2023 10:48:08 +0800 Subject: [PATCH] Add some log to print size of search result (#27601) Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/core/src/segcore/Reduce.cpp | 2 ++ internal/proxy/task_search.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/internal/core/src/segcore/Reduce.cpp b/internal/core/src/segcore/Reduce.cpp index 46ca71d84d..e3781e93d9 100644 --- a/internal/core/src/segcore/Reduce.cpp +++ b/internal/core/src/segcore/Reduce.cpp @@ -124,6 +124,8 @@ ReduceHelper::FillPrimaryKey() { uint32_t valid_index = 0; for (auto& search_result : search_results_) { FilterInvalidSearchResult(search_result); + LOG_SEGCORE_DEBUG_ << "the size of search result" + << search_result->seg_offsets_.size(); if (search_result->get_total_result_count() > 0) { auto segment = static_cast(search_result->segment_); diff --git a/internal/proxy/task_search.go b/internal/proxy/task_search.go index 1b58511f12..b5f7493914 100644 --- a/internal/proxy/task_search.go +++ b/internal/proxy/task_search.go @@ -796,10 +796,12 @@ func reduceSearchResultData(ctx context.Context, subSearchResultData []*schemapb } for i, sData := range subSearchResultData { + pkLength := typeutil.GetSizeOfIDs(sData.GetIds()) log.Ctx(ctx).Debug("subSearchResultData", zap.Int("result No.", i), zap.Int64("nq", sData.NumQueries), zap.Int64("topk", sData.TopK), + zap.Int("length of pks", pkLength), zap.Any("length of FieldsData", len(sData.FieldsData))) if err := checkSearchResultData(sData, nq, topk); err != nil { log.Ctx(ctx).Warn("invalid search results", zap.Error(err))