diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/RapidsBufferStore.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/RapidsBufferStore.scala index a23b0dd3aec..a3dbabc7b77 100644 --- a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/RapidsBufferStore.scala +++ b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/RapidsBufferStore.scala @@ -213,8 +213,10 @@ abstract class RapidsBufferStore( val bufferToSpill = buffers.nextSpillableBuffer() if (bufferToSpill != null) { spillAndFreeBuffer(bufferToSpill, stream) + bufferToSpill.size + } else { + 0 } - bufferToSpill.size } private def spillAndFreeBuffer(buffer: RapidsBufferBase, stream: Cuda.Stream): Unit = {