diff --git a/internal/core/src/index/VectorDiskIndex.cpp b/internal/core/src/index/VectorDiskIndex.cpp index 9f3cfabe37..339bef33e7 100644 --- a/internal/core/src/index/VectorDiskIndex.cpp +++ b/internal/core/src/index/VectorDiskIndex.cpp @@ -227,8 +227,8 @@ VectorDiskAnnIndex::Build(const Config& config) { ThrowInfo(ErrorCode::IndexBuildError, "failed to build disk index, " + KnowhereStatusString(stat)); - local_chunk_manager->RemoveDir( - storage::GetSegmentRawDataPathPrefix(local_chunk_manager, segment_id)); + local_chunk_manager->RemoveDir(storage::GenFieldRawDataPathPrefix( + local_chunk_manager, segment_id, field_id)); } template @@ -335,8 +335,8 @@ VectorDiskAnnIndex::BuildWithDataset(const DatasetPtr& dataset, file_manager_->AddFile(valid_data_path); } - local_chunk_manager->RemoveDir( - storage::GetSegmentRawDataPathPrefix(local_chunk_manager, segment_id)); + local_chunk_manager->RemoveDir(storage::GenFieldRawDataPathPrefix( + local_chunk_manager, segment_id, field_id)); // TODO :: // SetDim(index_->Dim()); diff --git a/internal/core/src/storage/Util.cpp b/internal/core/src/storage/Util.cpp index 8d83e36df3..785516d7af 100644 --- a/internal/core/src/storage/Util.cpp +++ b/internal/core/src/storage/Util.cpp @@ -942,15 +942,7 @@ GenFieldRawDataPathPrefix(ChunkManagerPtr cm, boost::filesystem::path prefix = cm->GetRootPath(); boost::filesystem::path path = std::string(RAWDATA_ROOT_PATH); boost::filesystem::path path1 = - std::to_string(segment_id) + "/" + std::to_string(field_id) + "/"; - return NormalizePath(prefix / path / path1); -} - -std::string -GetSegmentRawDataPathPrefix(ChunkManagerPtr cm, int64_t segment_id) { - boost::filesystem::path prefix = cm->GetRootPath(); - boost::filesystem::path path = std::string(RAWDATA_ROOT_PATH); - boost::filesystem::path path1 = std::to_string(segment_id); + std::to_string(segment_id) + "_" + std::to_string(field_id) + "/"; return NormalizePath(prefix / path / path1); }