diff --git a/hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java b/hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java index d4a77b0822847..3700d01a60ea6 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java @@ -291,13 +291,13 @@ private HFile.Reader fileIdIndexReader() { @Override public List getIndexedPartitionPaths() { - HFileScanner scanner = partitionIndexReader().getScanner(true, true); + HFileScanner scanner = partitionIndexReader().getScanner(true, false); return getAllKeys(scanner, HFileBootstrapIndex::getPartitionFromKey); } @Override public List getIndexedFileGroupIds() { - HFileScanner scanner = fileIdIndexReader().getScanner(true, true); + HFileScanner scanner = fileIdIndexReader().getScanner(true, false); return getAllKeys(scanner, HFileBootstrapIndex::getFileGroupFromKey); } @@ -319,7 +319,7 @@ private List getAllKeys(HFileScanner scanner, Function convert @Override public List getSourceFileMappingForPartition(String partition) { try { - HFileScanner scanner = partitionIndexReader().getScanner(true, true); + HFileScanner scanner = partitionIndexReader().getScanner(true, false); KeyValue keyValue = new KeyValue(Bytes.toBytes(getPartitionKey(partition)), new byte[0], new byte[0], HConstants.LATEST_TIMESTAMP, KeyValue.Type.Put, new byte[0]); if (scanner.seekTo(keyValue) == 0) { @@ -352,7 +352,7 @@ public Map getSourceFileMappingForFileI List fileGroupIds = new ArrayList<>(ids); Collections.sort(fileGroupIds); try { - HFileScanner scanner = fileIdIndexReader().getScanner(true, true); + HFileScanner scanner = fileIdIndexReader().getScanner(true, false); for (HoodieFileGroupId fileGroupId : fileGroupIds) { KeyValue keyValue = new KeyValue(Bytes.toBytes(getFileGroupKey(fileGroupId)), new byte[0], new byte[0], HConstants.LATEST_TIMESTAMP, KeyValue.Type.Put, new byte[0]); diff --git a/hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileReader.java b/hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileReader.java index 7b80d1a585974..e3e38eca86ca9 100644 --- a/hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileReader.java +++ b/hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileReader.java @@ -246,7 +246,7 @@ public Option getRecordByKey(String key, Schema readerSchema) throws IOException synchronized (this) { if (keyScanner == null) { - keyScanner = reader.getScanner(false, true); + keyScanner = reader.getScanner(false, false); } if (keyScanner.seekTo(kv) == 0) {