Loading core/src/db/DBImpl.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -706,7 +706,7 @@ DBImpl::MergeFiles(const std::string& table_id, const meta::DateT& date, const m // step 3: serialize to disk try { status = index->Serialize(); if (status.ok()) { if (!status.ok()) { ENGINE_LOG_ERROR << status.message(); } } catch (std::exception& ex) { Loading core/src/scheduler/task/BuildIndexTask.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -169,7 +169,7 @@ XBuildIndexTask::Execute() { // step 5: save index file try { status = index->Serialize(); if (status.ok()) { if (!status.ok()) { ENGINE_LOG_ERROR << status.message(); } } catch (std::exception& ex) { Loading core/src/server/grpc_impl/request/InsertRequest.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -45,7 +45,9 @@ InsertRequest::Create(const ::milvus::grpc::InsertParam* insert_param, ::milvus: Status InsertRequest::OnExecute() { try { TimeRecorder rc("InsertRequest"); std::string hdr = "InsertRequest(table=" + insert_param_->table_name() + ", n=" + std::to_string(insert_param_->row_record_array_size()) + ")"; TimeRecorder rc(hdr); // step 1: check arguments auto status = ValidationUtil::ValidateTableName(insert_param_->table_name()); Loading core/src/server/grpc_impl/request/SearchRequest.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -51,7 +51,9 @@ SearchRequest::OnExecute() { int64_t top_k = search_param_->topk(); int64_t nprobe = search_param_->nprobe(); std::string hdr = "SearchRequest(k=" + std::to_string(top_k) + ", nprob=" + std::to_string(nprobe) + ")"; std::string hdr = "SearchRequest(table=" + search_param_->table_name() + ", nq=" + std::to_string(search_param_->query_record_array_size()) + ", k=" + std::to_string(top_k) + ", nprob=" + std::to_string(nprobe) + ")"; TimeRecorder rc(hdr); // step 1: check table name Loading Loading
core/src/db/DBImpl.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -706,7 +706,7 @@ DBImpl::MergeFiles(const std::string& table_id, const meta::DateT& date, const m // step 3: serialize to disk try { status = index->Serialize(); if (status.ok()) { if (!status.ok()) { ENGINE_LOG_ERROR << status.message(); } } catch (std::exception& ex) { Loading
core/src/scheduler/task/BuildIndexTask.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -169,7 +169,7 @@ XBuildIndexTask::Execute() { // step 5: save index file try { status = index->Serialize(); if (status.ok()) { if (!status.ok()) { ENGINE_LOG_ERROR << status.message(); } } catch (std::exception& ex) { Loading
core/src/server/grpc_impl/request/InsertRequest.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -45,7 +45,9 @@ InsertRequest::Create(const ::milvus::grpc::InsertParam* insert_param, ::milvus: Status InsertRequest::OnExecute() { try { TimeRecorder rc("InsertRequest"); std::string hdr = "InsertRequest(table=" + insert_param_->table_name() + ", n=" + std::to_string(insert_param_->row_record_array_size()) + ")"; TimeRecorder rc(hdr); // step 1: check arguments auto status = ValidationUtil::ValidateTableName(insert_param_->table_name()); Loading
core/src/server/grpc_impl/request/SearchRequest.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -51,7 +51,9 @@ SearchRequest::OnExecute() { int64_t top_k = search_param_->topk(); int64_t nprobe = search_param_->nprobe(); std::string hdr = "SearchRequest(k=" + std::to_string(top_k) + ", nprob=" + std::to_string(nprobe) + ")"; std::string hdr = "SearchRequest(table=" + search_param_->table_name() + ", nq=" + std::to_string(search_param_->query_record_array_size()) + ", k=" + std::to_string(top_k) + ", nprob=" + std::to_string(nprobe) + ")"; TimeRecorder rc(hdr); // step 1: check table name Loading