fix(s3stream): stream compaction not working (#922)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Feb 5, 2024 · da52ecf · da52ecf
1 parent 28925da
commit da52ecf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java b/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java
@@ -98,7 +98,7 @@ private void startStreamObjectsCompactions() {
         scheduledCompactionTaskFuture = streamObjectCompactionScheduler.scheduleWithFixedDelay(() -> {
             List<S3Stream> operationStreams = new LinkedList<>(openedStreams.values());
             operationStreams.forEach(stream -> {
-                StreamObjectCompactor task = StreamObjectCompactor.builder().objectManager(objectManager)
+                StreamObjectCompactor task = StreamObjectCompactor.builder().objectManager(objectManager).stream(stream)
                     .s3Operator(s3Operator).maxStreamObjectSize(config.streamObjectCompactionMaxSizeBytes()).build();
                 task.compact();
             });