This is an automated email from the ASF dual-hosted git repository. stevel pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/hadoop.git
commit d3caa1552b143b1d578d69d3786ccdedf66e4557 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 (cherry picked from commit 5bf977e6b16287d7d140dd96dad66d0fce213954) --- .../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