(paimon) branch master updated: [benchmark] Close directory stream when loading sink configurations (#10138)

[lzljs3620320]

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

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 2275c56702 [benchmark] Close directory stream when loading sink 
configurations (#10138)
2275c56702 is described below

commit 2275c56702572cc1eb34feb3b3a74290f54f6bcb
Author: Ran Tao <chucheng...@gmail.com>
AuthorDate: Thu Sep 24 10:56:45 2026 +0800

    [benchmark] Close directory stream when loading sink configurations (#10138)
---
 .../java/org/apache/paimon/benchmark/Sink.java     | 27 ++++++++++++----------
 1 file changed, 15 insertions(+), 12 deletions(-)

diff --git 
a/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
 
b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
index e853d82ee1..2054b0c285 100644
--- 
a/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
+++ 
b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
@@ -30,6 +30,7 @@ import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Stream;
 
 /** Benchmark sink. */
 public class Sink {
@@ -66,18 +67,20 @@ public class Sink {
         Path sinkLocation = location.resolve("sinks");
 
         List<Sink> result = new ArrayList<>();
-        Iterator<Path> it = Files.list(sinkLocation).iterator();
-        while (it.hasNext()) {
-            Path p = it.next();
-            Map<?, ?> yaml =
-                    BenchmarkUtils.YAML_MAPPER.readValue(
-                            FileUtils.readFileUtf8(p.toFile()), Map.class);
-            result.add(
-                    new Sink(
-                            
FilenameUtils.removeExtension(p.getFileName().toString()),
-                            (String) yaml.get("before"),
-                            (String) yaml.get("sink-name"),
-                            (String) yaml.get("sink-properties")));
+        try (Stream<Path> paths = Files.list(sinkLocation)) {
+            Iterator<Path> it = paths.iterator();
+            while (it.hasNext()) {
+                Path p = it.next();
+                Map<?, ?> yaml =
+                        BenchmarkUtils.YAML_MAPPER.readValue(
+                                FileUtils.readFileUtf8(p.toFile()), Map.class);
+                result.add(
+                        new Sink(
+                                
FilenameUtils.removeExtension(p.getFileName().toString()),
+                                (String) yaml.get("before"),
+                                (String) yaml.get("sink-name"),
+                                (String) yaml.get("sink-properties")));
+            }
         }
         return result;
     }