diff --git a/src/service/compact/retention.rs b/src/service/compact/retention.rs index 00b24446a1..b67e91c624 100644 --- a/src/service/compact/retention.rs +++ b/src/service/compact/retention.rs @@ -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| {