diff --git a/src/main/scala/org/apache/spark/storage/S3DoubleBufferedStream.scala b/src/main/scala/org/apache/spark/storage/S3DoubleBufferedStream.scala index a39df15..89edc04 100644 --- a/src/main/scala/org/apache/spark/storage/S3DoubleBufferedStream.scala +++ b/src/main/scala/org/apache/spark/storage/S3DoubleBufferedStream.scala @@ -196,6 +196,7 @@ class S3DoubleBufferedStream(stream: S3ShuffleBlockStream, bufferSize: Int) exte stream.close() // Release buffers buffers = null + logInfo(s"Current buffer size: ${getBufferSize()}") } private def skipIn(buf: ByteBuffer, n: Int): Int = {