diff --git a/core/src/scheduler/task/SearchTask.cpp b/core/src/scheduler/task/SearchTask.cpp index f70fd65dff..7a71065346 100644 --- a/core/src/scheduler/task/SearchTask.cpp +++ b/core/src/scheduler/task/SearchTask.cpp @@ -317,6 +317,9 @@ XSearchTask::Execute() { std::unique_lock lock(search_job->mutex()); XSearchTask::MergeTopkToResultSet(output_ids, output_distance, spec_k, nq, topk, ascending_reduce, search_job->GetResultIds(), search_job->GetResultDistances()); + LOG_ENGINE_DEBUG_ << "Merged result: " + << "nq = " << nq << ", topk = " << topk << ", len of ids = " << output_ids.size() + << ", len of distance = " << output_distance.size(); } // span = rc.RecordSection(hdr + ", reduce topk"); diff --git a/core/src/server/grpc_impl/GrpcRequestHandler.cpp b/core/src/server/grpc_impl/GrpcRequestHandler.cpp index 2bd7eed694..a0d072891d 100644 --- a/core/src/server/grpc_impl/GrpcRequestHandler.cpp +++ b/core/src/server/grpc_impl/GrpcRequestHandler.cpp @@ -519,6 +519,9 @@ GrpcRequestHandler::Search(::grpc::ServerContext* context, const ::milvus::grpc: Status status = request_handler_.Search(GetContext(context), request->collection_name(), vectors, request->topk(), json_params, partitions, file_ids, result); + LOG_SERVER_DEBUG_C << "row num = " << result.row_num_ << ", id list length = " << result.id_list_.size() + << ", distance list length = " << result.distance_list_.size(); + // step 5: construct and return result ConstructResults(result, response);