chore(compaction): supress error

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Feb 19, 2024 · af04302 · af04302
1 parent 41926bc
commit af04302
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);
         }
     }