Log buffer size.

Signed-off-by: Pascal Spörri <[email protected]>
IBM · Aug 24, 2023 · 2fa9e10 · 2fa9e10
1 parent 050e212
commit 2fa9e10
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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 = {