Merge pull request #104 from upserve/file_descriptor_leak

Fix file descriptor leak in Files.list method. Stream must be closed.
upserve · Aug 26, 2019 · 7d8e6fa · 7d8e6fa
2 parents 8515f69 + 6289f63
commit 7d8e6fa
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main/java/com/upserve/uppend/FileStore.java b/src/main/java/com/upserve/uppend/FileStore.java
@@ -125,9 +125,8 @@ T getOrCreate(String partitionEntropy) {
     }
 
     Stream<T> streamPartitions() {
-        try {
-            Files
-                    .list(partitionsDir)
+        try (Stream<Path> stream = Files.list(partitionsDir)){
+            stream
                     .map(path -> path.toFile().getName())
                     .forEach(partition -> partitionMap.computeIfAbsent(
                             partition,