From d646bcba8b2bb110cd0f344f0dfe3bf82bbba686 Mon Sep 17 00:00:00 2001
From: Hengfei Yang <hengfei.yang@gmail.com>
Date: Wed, 20 Aug 2025 09:05:03 +0800
Subject: [PATCH] fix: add logs for compactor (#8045)

---
 src/service/compact/retention.rs | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

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| {