Fixing closure of file slice readers w/ mdt reader

apache · Nov 28, 2024 · 9970bfa · 9970bfa
1 parent 5c28762
commit 9970bfa
Showing 1 changed file with 4 additions and 0 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
@@ -458,6 +458,10 @@ private Map<String, List<HoodieRecord<HoodieMetadataPayload>>> lookupAllKeysFrom
       return readFromBaseAndMergeWithAllLogRecords(baseFileReader, sortedKeys, true, logRecords, timings, partitionName);
     } catch (IOException ioe) {
       throw new HoodieIOException("Error merging records from metadata table for  " + keys.size() + " key : ", ioe);
+    } finally {
+      if (!reuse) {
+        closeReader(readers);
+      }
     }
   }