1

apache · Dec 29, 2024 · 8ab1247 · 8ab1247
1 parent d59cdaa
commit 8ab1247
Showing 1 changed file with 3 additions and 3 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
@@ -876,9 +876,9 @@ private Map<String, HoodieRecord<HoodieMetadataPayload>> fetchBaseFileAllRecords
 
     try (ClosableIterator<? extends HoodieRecord<?>> recordIterator = reader.getRecordIterator()) {
       return toStream(recordIterator).map(record -> {
-            GenericRecord data = (GenericRecord) record.getData();
-            return composeRecord(data, partitionName);
-          }).filter(record -> keySet.contains(SecondaryIndexKeyUtils
+        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()),