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

   ### Purpose
   
   Fixes #10531.
   
   The file source `GZ` archive path created a `GzipCompressorInputStream` 
without try-with-resources. If `readProcess` failed while consuming the 
decompressed stream, the gzip stream and its underlying Hadoop input stream 
could remain open.
   
   ### Changes
   
   - Wrap the `GZ` branch in `AbstractReadStrategy` with try-with-resources.
   - Keep the existing gzip metadata filename fallback behavior unchanged.
   - Add a regression test that forces `readProcess` to fail and verifies the 
original gzip input stream is closed.
   
   ### Verification
   
   - `./mvnw spotless:apply`
   - `./mvnw -q -DskipTests verify`
   - `./mvnw -pl seatunnel-connectors-v2/connector-file/connector-file-base 
-DskipIT -Dcheckstyle.skip -Dspotless.check.skip=true 
-Dtest=AbstractReadStrategyTest test`
   - `./mvnw -pl seatunnel-connectors-v2/connector-file/connector-file-base 
-DskipIT -Dcheckstyle.skip -Dspotless.check.skip=true test`
   


-- 
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