Skip to content

Commit 2b4f790

Browse files
yuezhangyihua
authored andcommitted
close readers if set reuse false
1 parent 7ae49fc commit 2b4f790

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,6 @@
1818

1919
package org.apache.hudi.metadata;
2020

21-
import org.apache.avro.Schema;
22-
import org.apache.avro.generic.GenericRecord;
23-
import org.apache.hadoop.fs.Path;
2421
import org.apache.hudi.avro.HoodieAvroUtils;
2522
import org.apache.hudi.avro.model.HoodieMetadataRecord;
2623
import org.apache.hudi.avro.model.HoodieRestoreMetadata;
@@ -53,9 +50,12 @@
5350
import org.apache.hudi.exception.TableNotFoundException;
5451
import org.apache.hudi.io.storage.HoodieFileReader;
5552
import org.apache.hudi.io.storage.HoodieFileReaderFactory;
53+
54+
import org.apache.avro.Schema;
55+
import org.apache.avro.generic.GenericRecord;
56+
import org.apache.hadoop.fs.Path;
5657
import org.apache.log4j.LogManager;
5758
import org.apache.log4j.Logger;
58-
import org.jetbrains.annotations.NotNull;
5959

6060
import java.io.IOException;
6161
import java.util.ArrayList;
@@ -230,7 +230,7 @@ public List<Pair<String, Option<HoodieRecord<HoodieMetadataPayload>>>> getRecord
230230
throw new HoodieIOException("Error merging records from metadata table for " + sortedKeys.size() + " key : ", ioe);
231231
} finally {
232232
if (!reuse) {
233-
close(Pair.of(partitionFileSlicePair.getLeft(), partitionFileSlicePair.getRight().getFileId()));
233+
closeReader(readers);
234234
}
235235
}
236236
});

0 commit comments

Comments
 (0)