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

fix: fix remove index type failed when remote storage is local mode (#41163)

Browse Source 
pr: #41164

Signed-off-by: luzhang <luzhang@zilliz.com>
Co-authored-by: luzhang <luzhang@zilliz.com>
This commit is contained in:
zhagnlu 2025-04-09 10:14:27 +08:00 committed by GitHub
parent 8c52fbfe0d
commit fe88a243d1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
internal/core/src/index/InvertedIndexTantivy.cpp
View File

@ -178,24 +178,26 @@ InvertedIndexTantivy<T>::Load(milvus::tracer::TraceContext ctx,
auto inverted_index_files = index_files.value();
// need erase the index type file that has been readed
auto index_type_file =
disk_file_manager_->GetRemoteIndexPrefix() + std::string("/index_type");
inverted_index_files.erase(
std::remove_if(
inverted_index_files.begin(),
inverted_index_files.end(),
[&](const std::string& file) { return file == index_type_file; }),
inverted_index_files.end());
auto GetFileName = [](const std::string& path) -> std::string {
auto pos = path.find_last_of('/');
return pos == std::string::npos ? path : path.substr(pos + 1);
};
inverted_index_files.erase(std::remove_if(inverted_index_files.begin(),
inverted_index_files.end(),
[&](const std::string& file) {
return GetFileName(file) ==
"index_type";
}),
inverted_index_files.end());
std::vector<std::string> null_offset_files;
std::shared_ptr<FieldDataBase> null_offset_data;
auto find_file = [&](const std::string& file) -> auto {
auto find_file = [&](const std::string& target) -> auto {
return std::find_if(inverted_index_files.begin(),
inverted_index_files.end(),
[&](const std::string& f) {
return f.substr(f.find_last_of('/') + 1) ==
file;
[&](const std::string& filename) {
return GetFileName(filename) == target;
});
};