fix

apache · Dec 29, 2024 · 290aad6 · 290aad6
1 parent 90298f2
commit 290aad6
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java
@@ -908,15 +908,15 @@ private Map<String, HoodieRecord<HoodieMetadataPayload>> fetchBaseFileAllRecords
       return Collections.emptyMap();
     }
 
-    ClosableIterator<HoodieRecord<?>> recordIterator = reader.getRecordIterator();
-
-    return toStream(recordIterator).map(record -> {
-      GenericRecord data = (GenericRecord) record.getData();
-      return composeRecord(data, partitionName);
-    }).filter(record -> {
-      return keySet.contains(SecondaryIndexKeyUtils.getRecordKeyFromSecondaryIndexKey(record.getRecordKey()));
-    }).collect(Collectors.toMap(record -> {
-      return SecondaryIndexKeyUtils.getRecordKeyFromSecondaryIndexKey(record.getRecordKey());
-    }, record -> record));
+    try (ClosableIterator<HoodieRecord<?>> recordIterator = reader.getRecordIterator()) {
+      return toStream(recordIterator).map(record -> {
+            GenericRecord data = (GenericRecord) record.getData();
+            return composeRecord(data, partitionName);
+          }).filter(record -> keySet.contains(SecondaryIndexKeyUtils
+              .getRecordKeyFromSecondaryIndexKey(record.getRecordKey())))
+          .collect(Collectors.toMap(record ->
+                  SecondaryIndexKeyUtils.getRecordKeyFromSecondaryIndexKey(record.getRecordKey()),
+              record -> record));
+    }
   }
 }