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

[ki...@apache.org]

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

kirs 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 71d098b  [Bug] [core] Fix the resource leak for SparkStarter (#1655)
71d098b is described below

commit 71d098bc93dada1f8276be6e2be24340599eb616
Author: Benedict Jin <as...@apache.org>
AuthorDate: Sun Apr 3 00:28:12 2022 +0800

    [Bug] [core] Fix the resource leak for SparkStarter (#1655)
---
 .../src/main/java/org/apache/seatunnel/SparkStarter.java       | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SparkStarter.java b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SparkStarter.java
index b929bd2..2b51a2d 100644
--- a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SparkStarter.java
+++ b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SparkStarter.java
@@ -208,10 +208,12 @@ public class SparkStarter implements Starter {
      * list jars in given directory
      */
     private List<Path> listJars(Path dir) throws IOException {
-        return Files.list(dir)
-            .filter(it -> !Files.isDirectory(it))
-            .filter(it -> it.getFileName().endsWith("jar"))
-            .collect(Collectors.toList());
+        try (Stream<Path> stream = Files.list(dir)) {
+            return stream
+                    .filter(it -> !Files.isDirectory(it))
+                    .filter(it -> it.getFileName().endsWith("jar"))
+                    .collect(Collectors.toList());
+        }
     }
 
     /**