starred/openobserve
1
0
Fork 0
mirror of https://github.com/openobserve/openobserve.git synced 2026-11-05 00:09:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: compactor with extended retention (#5571)

Browse Source
This commit is contained in:
Hengfei Yang
2025-01-03 18:36:25 +08:00
committed by GitHub
parent c32c9dac7b
commit d9b6f2fedb
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/compact/retention.rs
+3 -7
View File
@@ -432,13 +432,9 @@ pub async fn delete_by_date(
// update stream stats retention time
let mut stats = cache::stats::get_stream_stats(org_id, stream_name, stream_type);
let mut min_ts = if time_range.1 > BASE_TIME.timestamp_micros() {
time_range.1
} else {
infra_file_list::get_min_ts(org_id, stream_type, stream_name)
.await
.unwrap_or_default()
};
let mut min_ts = infra_file_list::get_min_ts(org_id, stream_type, stream_name)
.await
.unwrap_or_default();
if min_ts == 0 {
min_ts = stats.doc_time_min;
};