From 9d27cf611b0d6e9d5986f989b1c9ea073cdf61f7 Mon Sep 17 00:00:00 2001 From: humengyu Date: Thu, 13 Jul 2023 14:04:46 +0800 Subject: [PATCH] Fix memory leaking when loading data: https://github.com/Alluxio/alluxio/pull/17758 --- .../java/alluxio/worker/block/MonoBlockStore.java | 4 ++-- joker.yml | 13 +++++++++++++ 2 files changed, 15 insertions(+), 2 deletions(-) create mode 100644 joker.yml 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 index 26b2757c885c..9c475df0e6d0 100644 --- a/core/server/worker/src/main/java/alluxio/worker/block/MonoBlockStore.java +++ b/core/server/worker/src/main/java/alluxio/worker/block/MonoBlockStore.java @@ -339,12 +339,12 @@ public CompletableFuture> load(List blocks, UfsReadOpti blockWriter.close(); } catch (IOException e) { throw AlluxioRuntimeException.from(e); - } finally { - NioDirectBufferPool.release(buf); } }) .thenRun(() -> commitBlock(sessionId, blockId, false)) + .thenRun(() -> NioDirectBufferPool.release(buf)) .exceptionally(t -> { + NioDirectBufferPool.release(buf); handleException(t.getCause(), block, errors, sessionId); return null; }); diff --git a/joker.yml b/joker.yml new file mode 100644 index 000000000000..a61ecdb0b381 --- /dev/null +++ b/joker.yml @@ -0,0 +1,13 @@ +version: 2.0 +base_image: bionic +components: + java: 1.8 + +build: + - echo 0 + +test: + unittest: + - echo 0 + +