chore(compaction): suppress error (#929)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Feb 19, 2024 · 5b1cd92 · 5b1cd92
1 parent 41926bc
commit 5b1cd92
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/StreamObjectCompactor.java b/s3stream/src/main/java/com/automq/stream/s3/StreamObjectCompactor.java
@@ -71,7 +71,7 @@ public void compact() {
         try {
             compact0(false);
         } catch (Throwable e) {
-            LOGGER.error("Failed to compact {} stream objects", stream.streamId(), e);
+            handleCompactException(e);
         }
     }
 
@@ -82,7 +82,15 @@ public void cleanup() {
         try {
             compact0(true);
         } catch (Throwable e) {
-            LOGGER.error("Failed to compact {} stream objects", stream.streamId(), e);
+            handleCompactException(e);
+        }
+    }
+
+    private void handleCompactException(Throwable e) {
+        if (stream instanceof S3StreamClient.StreamWrapper && ((S3StreamClient.StreamWrapper) stream).isClosed()) {
+            LOGGER.warn("[STREAM_OBJECT_COMPACT_FAIL],[STREAM_CLOSED],{}", stream.streamId(), e);
+        } else {
+            LOGGER.error("[STREAM_OBJECT_COMPACT_FAIL],[UNEXPECTED],{}", stream.streamId(), e);
         }
     }