fix: suppress stream object compaction error (#939)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Feb 21, 2024 · 31a3f61 · 31a3f61
1 parent 7a26b6c
commit 31a3f61
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
@@ -239,7 +239,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();