Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Hadoop-17413. Release elastic byte buffer pool at close 

- Contributed by Sneha Vijayarajan

(cherry picked from commit 5bf977e6b1)
This commit is contained in:
Sneha Vijayarajan 2020-12-15 10:15:37 +05:30 committed by Steve Loughran
parent a44890eb63
commit d3caa1552b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java
View File

@ -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 * blocks. After the data is sent to the service, the buffer is returned
* back to the queue * back to the queue
*/ */
private final ElasticByteBufferPool byteBufferPool private ElasticByteBufferPool byteBufferPool
= new ElasticByteBufferPool(); = new ElasticByteBufferPool();
private final Statistics statistics; private final Statistics statistics;
@ -297,6 +297,7 @@ public class AbfsOutputStream extends OutputStream implements Syncable, StreamCa
bufferIndex = 0; bufferIndex = 0;
closed = true; closed = true;
writeOperations.clear(); writeOperations.clear();
byteBufferPool = null;
if (!threadExecutor.isShutdown()) { if (!threadExecutor.isShutdown()) {
threadExecutor.shutdownNow(); threadExecutor.shutdownNow();
} }