admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add segcore error messages (#8681)

Browse Source 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-09-27 20:30:23 +08:00 committed by GitHub
parent 64f158de78
commit ff3573c921
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/core/src/indexbuilder/IndexWrapper.cpp
View File

@ -38,7 +38,7 @@ IndexWrapper::IndexWrapper(const char* serialized_type_params, const char* seria
AssertInfo(!is_unsupported(index_type, metric_type), index_type + " doesn't support metric: " + metric_type);
index_ = knowhere::VecIndexFactory::GetInstance().CreateVecIndex(get_index_type(), index_mode);
Assert(index_ != nullptr);
AssertInfo(index_ != nullptr, "[IndexWrapper]Index is null after create index");
}
template <typename ParamsT> // ugly here, ParamsT will just be MapParams later
@ -48,7 +48,7 @@ IndexWrapper::parse_impl(const std::string& serialized_params_str, knowhere::Con
ParamsT params;
deserialized_success = google::protobuf::TextFormat::ParseFromString(serialized_params_str, &params);
Assert(deserialized_success);
AssertInfo(deserialized_success, "[IndexWrapper]Deserialize params failed");
for (auto i = 0; i < params.params_size(); ++i) {
const auto& param = params.params(i);
@ -150,7 +150,7 @@ IndexWrapper::get_config_by_name(std::string name) {
int64_t
IndexWrapper::dim() {
auto dimension = get_config_by_name<int64_t>(milvus::knowhere::meta::DIM);
Assert(dimension.has_value());
AssertInfo(dimension.has_value(), "[IndexWrapper]Dimension doesn't have value");
return (dimension.value());
}
@ -190,7 +190,8 @@ IndexWrapper::BuildWithoutIds(const knowhere::DatasetPtr& dataset) {
void
IndexWrapper::BuildWithIds(const knowhere::DatasetPtr& dataset) {
Assert(dataset->data().find(milvus::knowhere::meta::IDS) != dataset->data().end());
AssertInfo(dataset->data().find(milvus::knowhere::meta::IDS) != dataset->data().end(),
"[IndexWrapper]Can't find ids field in dataset");
auto index_type = get_index_type();
auto index_mode = get_index_mode();
config_[knowhere::meta::ROWS] = dataset->Get<int64_t>(knowhere::meta::ROWS);
@ -257,7 +258,7 @@ IndexWrapper::Serialize() {
std::string serialized_data;
auto ok = ret.SerializeToString(&serialized_data);
Assert(ok);
AssertInfo(ok, "[IndexWrapper]Can't serialize data to string");
auto binary = std::make_unique<IndexWrapper::Binary>();
binary->data.resize(serialized_data.length());
@ -273,7 +274,7 @@ IndexWrapper::Load(const char* serialized_sliced_blob_buffer, int32_t size) {
indexcgo::BinarySet blob_buffer;
auto ok = blob_buffer.ParseFromString(data);
Assert(ok);
AssertInfo(ok, "[IndexWrapper]Can't parse data from string to blob_buffer");
milvus::knowhere::BinarySet binarySet;
for (auto i = 0; i < blob_buffer.datas_size(); i++) {

3
internal/core/src/segcore/SegmentSealedImpl.cpp
View File

@ -226,7 +226,8 @@ SegmentSealedImpl::vector_search(int64_t vec_count,
AssertInfo(field_meta.is_vector(), "The meta type of vector field is not vector type");
if (get_bit(vecindex_ready_bitset_, field_offset)) {
AssertInfo(vecindexs_.is_ready(field_offset), "");
AssertInfo(vecindexs_.is_ready(field_offset),
"vector indexes isn't ready for field " + std::to_string(field_offset.get()));
query::SearchOnSealed(*schema_, vecindexs_, search_info, query_data, query_count, bitset, output);
return;
} else if (!get_bit(field_data_ready_bitset_, field_offset)) {