From 9970bfa9c303ffc422afbcdea6071a4b6de85f6e Mon Sep 17 00:00:00 2001 From: sivabalan Date: Thu, 28 Nov 2024 08:35:18 -0800 Subject: [PATCH] Fixing closure of file slice readers w/ mdt reader --- .../org/apache/hudi/metadata/HoodieBackedTableMetadata.java | 4 ++++ 1 file changed, 4 insertions(+) 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 index d63b64bfa053c..21652df07188e 100644 --- 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>> 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); + } } }