From 407af185df074a5fae69440301810bb112addba4 Mon Sep 17 00:00:00 2001
From: Shichao Nie <niesc@automq.com>
Date: Tue, 24 Dec 2024 17:14:22 +0800
Subject: [PATCH] fix(s3stream): report compaction delay after two compaction
 period (#2243)

Signed-off-by: Shichao Nie <niesc@automq.com>
---
 .../java/com/automq/stream/s3/compact/CompactionManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/s3stream/src/main/java/com/automq/stream/s3/compact/CompactionManager.java b/s3stream/src/main/java/com/automq/stream/s3/compact/CompactionManager.java
index dc25e6e17e..b7e8610025 100644
--- a/s3stream/src/main/java/com/automq/stream/s3/compact/CompactionManager.java
+++ b/s3stream/src/main/java/com/automq/stream/s3/compact/CompactionManager.java
@@ -148,7 +148,7 @@ public void start() {
                 }
                 data.sort(Comparator.comparingLong(S3ObjectMetadata::committedTimestamp));
                 this.compactionDelayTime = System.currentTimeMillis() - data.get(0).committedTimestamp();
-            }).join(), 1, 1, TimeUnit.MINUTES);
+            }).join(), (long) this.compactionInterval * 2, 1, TimeUnit.MINUTES);
     }
 
     void scheduleNextCompaction(long delayMillis) {