normanmaurer commented on code in PR #4597:
URL: https://github.com/apache/hbase/pull/4597#discussion_r915650204
##########
hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutput.java:
##########
@@ -429,6 +429,9 @@ private void flushBuffer(CompletableFuture<Long> future,
ByteBuf dataBuf,
future.completeExceptionally(new IOException("stream already broken"));
// it's the one we have just pushed or just a no-op
waitingAckQueue.removeFirst();
+
+ // This method takes ownership of the dataBuf so we need release it
before returning.
+ dataBuf.release();
Review Comment:
(I added the explicit release calls)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
