Skip to content

Commit e815f82

Browse files
authored
fix(revert): error callback (#1851)
Revert "fix(s3stream): error callback (#1845)" This reverts commit 31e2f4e.
1 parent 31e2f4e commit e815f82

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

s3stream/src/main/java/com/automq/stream/s3/S3Storage.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -486,6 +486,7 @@ public boolean append0(AppendContext context, WalWriteRequest request, boolean f
486486
if (ex != null) {
487487
LOGGER.error("append WAL fail, request {}", request, ex);
488488
storageFailureHandler.handle(ex);
489+
return;
489490
}
490491
handleAppendCallback(request);
491492
});

0 commit comments

Comments
 (0)