Skip to content

Commit

Permalink
Release buffer after close writer
Browse files Browse the repository at this point in the history
  • Loading branch information
Haoning-Sun committed Jul 11, 2023
1 parent 147ca4b commit f9f96bf
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -345,10 +345,9 @@ public CompletableFuture<List<BlockStatus>> load(List<Block> blocks, UfsReadOpti
.thenRun(() -> {
try {
blockWriter.close();
NioDirectBufferPool.release(buf);
} catch (IOException e) {
throw AlluxioRuntimeException.from(e);
} finally {
NioDirectBufferPool.release(buf);
}
})
.thenRun(() -> commitBlock(sessionId, blockId, false))
Expand Down

0 comments on commit f9f96bf

Please sign in to comment.