diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java b/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java
index 2036c16a9..31e55dad4 100644
--- a/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java
+++ b/s3stream/src/main/java/com/automq/stream/s3/S3StreamClient.java
@@ -238,7 +238,7 @@ public void compactStreamObject0(boolean onlyCleanup) {
             }
             try {
                 compacting = true;
-                StreamObjectCompactor task = StreamObjectCompactor.builder().objectManager(objectManager).stream(stream)
+                StreamObjectCompactor task = StreamObjectCompactor.builder().objectManager(objectManager).stream(this)
                     .s3Operator(s3Operator).maxStreamObjectSize(config.streamObjectCompactionMaxSizeBytes()).build();
                 if (onlyCleanup) {
                     task.cleanup();