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

fix: add logs for compactor (#8045)

Browse Source
This commit is contained in:
Hengfei Yang
2025-08-20 09:05:03 +08:00
committed by GitHub
parent ca99331c98
commit d646bcba8b
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/compact/retention.rs
+9 -2
View File
@@ -213,8 +213,8 @@ pub async fn delete_by_stream(
continue;
}
log::debug!(
"[COMPACTOR] delete_by_stream {org_id}/{stream_type}/{stream_name}/{time_range_start},{time_range_end}",
log::info!(
"[COMPACTOR] delete_by_stream: generate job for {org_id}/{stream_type}/{stream_name}/{time_range_start},{time_range_end}",
);
db::compact::retention::delete_stream(
@@ -362,6 +362,13 @@ pub async fn delete_by_date(
}
// delete from file list
log::info!(
"[COMPACTOR] delete_by_date: delete_from_file_list {}/{}/{}/{:?}",
org_id,
stream_type,
stream_name,
time_range
);
delete_from_file_list(org_id, stream_type, stream_name, time_range)
.await
.map_err(|e| {