Skip to content

Commit

Permalink
Make sure that the chunked packer bounce buffer is realease after the…
Browse files Browse the repository at this point in the history
… synchronize (#11887)

Signed-off-by: Alessandro Bellina <abellina@nvidia.com>
  • Loading branch information
abellina authored Dec 19, 2024
1 parent 62b2396 commit 0e5b5cb
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1719,7 +1719,7 @@ class ChunkedPacker(table: Table,
}

override def next(): (DeviceBounceBuffer, Long) = {
withResource(bounceBufferPool.nextBuffer()) { bounceBuffer =>
closeOnExcept(bounceBufferPool.nextBuffer()) { bounceBuffer =>
if (closed) {
throw new IllegalStateException(s"ChunkedPacker is closed")
}
Expand Down

0 comments on commit 0e5b5cb

Please sign in to comment.