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

Signed-off-by: Alessandro Bellina <[email protected]>
  • Loading branch information
abellina committed Dec 18, 2024
1 parent 3f26d33 commit a19bfb4
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 a19bfb4

Please sign in to comment.