zhangshenghang opened a new pull request, #11593:
URL: https://github.com/apache/seatunnel/pull/11593

   ## What does this PR do?
   
   Fixes #9863 by releasing Arrow stream-reader resources before closing their 
allocator.
   
   ## Root cause
   
   The previous cleanup order closed the root allocator before 
`ArrowStreamReader`. The stream reader can still own Arrow buffers at that 
point, so the allocator reports a memory leak and fails the source read.
   
   ## Changes
   
   - Close `ArrowStreamReader` before its allocator and let it release the 
vector schema root it owns.
   - Close the backing byte stream after the reader.
   - Add a regression test covering automatic resource cleanup after Arrow 
deserialization.
   
   ## Verification
   
   - `./mvnw -pl seatunnel-connectors-v2/connector-common 
-Dtest=ArrowToSeatunnelRowReaderTest test`
   - `./mvnw spotless:apply`
   - `./mvnw -q -DskipTests verify`


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to