rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-22 07:50:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: condition for add files

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2025-12-11 10:56:59 +08:00
parent bd1a9da216
commit e154eb65b1
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/mito2/src/sst/version.rs
View File

@@ -63,10 +63,18 @@ impl SstVersion {
.files
.entry(file.file_id)
.and_modify(|f| {
if f.index_id().version < new_index_version {
*f = FileHandle::new(file.clone(), file_purger.clone());
} else {
if f.meta_ref().exists_index() && f.index_id().version >= new_index_version {
// current file handle's index is up-to-date, skip adding
if f.index_id().version > new_index_version {
common_telemetry::warn!(
"Adding file with older index version, existing: {:?}, new: {:?}, ignoring new file",
f.meta_ref(),
file
);
}
} else {
// include case like old file have no index or index is outdated
*f = FileHandle::new(file.clone(), file_purger.clone());
}
})
.or_insert_with(|| FileHandle::new(file.clone(), file_purger.clone()));