fix(wal): fix leak caused by #3000 (#3007)

superhx · web-flow · commit 4226b5038f83 · 2025-11-14T10:54:43.000+08:00
Signed-off-by: Robin Han &lt;hanxvdovehx@gmail.com&gt;
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/impl/object/DefaultReader.java b/s3stream/src/main/java/com/automq/stream/s3/wal/impl/object/DefaultReader.java
@@ -195,6 +195,8 @@ private void doRunBatchGet0(BatchReadTask readTask) {
                                     boolean isTriggerTrimRecord = batch.getCount() == 0 && batch.getStreamId() == -1L && batch.getEpoch() == -1L;
                                     if (!isTriggerTrimRecord) {
                                         batches.add(batch);
+                                    } else {
+                                        batch.release();
                                     }
                                     nextRecordOffset += lastReadableBytes - buf.readableBytes();
                                     lastReadableBytes = buf.readableBytes();

Original file line number	Diff line number	Diff line change
`@@ -195,6 +195,8 @@ private void doRunBatchGet0(BatchReadTask readTask) {`
`195`	`195`	`boolean isTriggerTrimRecord = batch.getCount() == 0 && batch.getStreamId() == -1L && batch.getEpoch() == -1L;`
`196`	`196`	`if (!isTriggerTrimRecord) {`
`197`	`197`	`batches.add(batch);`
	`198`	`+ } else {`
	`199`	`+ batch.release();`
`198`	`200`	`}`
`199`	`201`	`nextRecordOffset += lastReadableBytes - buf.readableBytes();`
`200`	`202`	`lastReadableBytes = buf.readableBytes();`