From d9b6f2fedb9ad294111b2d7d450cf2d85cd64d02 Mon Sep 17 00:00:00 2001
From: Hengfei Yang <hengfei.yang@gmail.com>
Date: Fri, 3 Jan 2025 18:36:25 +0800
Subject: [PATCH] fix: compactor with extended retention (#5571)

---
 src/service/compact/retention.rs | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git a/src/service/compact/retention.rs b/src/service/compact/retention.rs
index 0bb511d573..4fe01349ce 100644
--- a/src/service/compact/retention.rs
+++ b/src/service/compact/retention.rs
@@ -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;
     };