Fix memory leaking when loading data

Alluxio · Jul 11, 2023 · 147ca4b · 147ca4b
1 parent c237203
commit 147ca4b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/server/worker/src/main/java/alluxio/worker/block/MonoBlockStore.java b/core/server/worker/src/main/java/alluxio/worker/block/MonoBlockStore.java
@@ -353,6 +353,7 @@ public CompletableFuture<List<BlockStatus>> load(List<Block> blocks, UfsReadOpti
           })
           .thenRun(() -> commitBlock(sessionId, blockId, false))
           .exceptionally(t -> {
+            NioDirectBufferPool.release(buf);
             handleException(t.getCause(), block, errors, sessionId);
             return null;
           });