This is an automated email from the ASF dual-hosted git repository. dazhou pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push: new 5bf977e Hadoop-17413. Release elastic byte buffer pool at close 5bf977e is described below commit 5bf977e6b16287d7d140dd96dad66d0fce213954 Author: Sneha Vijayarajan <sneha.vijayara...@gmail.com> AuthorDate: Tue Dec 15 10:15:37 2020 +0530 Hadoop-17413. Release elastic byte buffer pool at close - Contributed by Sneha Vijayarajan --- .../java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java index b53b2b2..01b2fa5 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java @@ -85,7 +85,7 @@ public class AbfsOutputStream extends OutputStream implements Syncable, StreamCa * blocks. After the data is sent to the service, the buffer is returned * back to the queue */ - private final ElasticByteBufferPool byteBufferPool + private ElasticByteBufferPool byteBufferPool = new ElasticByteBufferPool(); private final Statistics statistics; @@ -297,6 +297,7 @@ public class AbfsOutputStream extends OutputStream implements Syncable, StreamCa bufferIndex = 0; closed = true; writeOperations.clear(); + byteBufferPool = null; if (!threadExecutor.isShutdown()) { threadExecutor.shutdownNow(); } --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org