fix(s3stream): fix duplicated release (#459)

Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
AutoMQ · Oct 25, 2023 · adb5b70 · adb5b70
1 parent e585bd7
commit adb5b70
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/ProxyWriter.java b/s3stream/src/main/java/com/automq/stream/s3/operator/ProxyWriter.java
@@ -123,7 +123,6 @@ public boolean hasBatchingPart() {
         @Override
         public CompletableFuture<Void> close() {
             FutureUtil.propagate(operator.write(path, data, throttleStrategy), cf);
-            cf.whenComplete((nil, ex) -> data.release());
             return cf;
         }