fix(s3stream): report compaction delay after two compaction period (#2242)

SCNieh · web-flow · commit 9502ac369677 · 2024-12-24T17:14:19.000+08:00
Signed-off-by: Shichao Nie &lt;niesc@automq.com&gt;
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
@@ -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) {

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ public void start() {`
`148`	`148`	`}`
`149`	`149`	`data.sort(Comparator.comparingLong(S3ObjectMetadata::committedTimestamp));`
`150`	`150`	`this.compactionDelayTime = System.currentTimeMillis() - data.get(0).committedTimestamp();`
`151`		`- }).join(), 1, 1, TimeUnit.MINUTES);`
	`151`	`+ }).join(), (long) this.compactionInterval * 2, 1, TimeUnit.MINUTES);`
`152`	`152`	`}`
`153`	`153`
`154`	`154`	`void scheduleNextCompaction(long delayMillis) {`