[incubator-seatunnel] branch dev updated: [Bug] [core] Fix the resource leak for unGzip (#1555)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0295d0f  [Bug] [core] Fix the resource leak for unGzip (#1555)
0295d0f is described below

commit 0295d0f58d8248902a458db53f976ac33c4336aa
Author: Benedict Jin <asdf2...@apache.org>
AuthorDate: Thu Mar 24 23:53:05 2022 +0800

    [Bug] [core] Fix the resource leak for unGzip (#1555)
---
 .../java/org/apache/seatunnel/utils/CompressionUtils.java   | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git 
a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/utils/CompressionUtils.java
 
b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/utils/CompressionUtils.java
index e2666f2..09fe2b3 100644
--- 
a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/utils/CompressionUtils.java
+++ 
b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/utils/CompressionUtils.java
@@ -102,14 +102,11 @@ public final class CompressionUtils {
 
         final File outputFile = new File(outputDir, 
inputFile.getName().substring(0, inputFile.getName().length() - 3));
 
-        final GZIPInputStream in = new GZIPInputStream(new 
FileInputStream(inputFile));
-        final FileOutputStream out = new FileOutputStream(outputFile);
-
-        IOUtils.copy(in, out);
-
-        in.close();
-        out.close();
-
+        try (final FileInputStream fis = new FileInputStream(inputFile);
+             final GZIPInputStream in = new GZIPInputStream(fis);
+             final FileOutputStream out = new FileOutputStream(outputFile)) {
+            IOUtils.copy(in, out);
+        }
         return outputFile;
     }