[HUDI-4270] Bootstrap op data loading missing (apache#5888)

(cherry picked from commit 7c4aaa9)
danny0405 · Jul 22, 2022 · 90fa31e · 90fa31e
1 parent 622d27a
commit 90fa31e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java b/...datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java
@@ -22,6 +22,7 @@
 import org.apache.hudi.common.model.FileSlice;
 import org.apache.hudi.common.model.HoodieAvroRecord;
 import org.apache.hudi.common.model.HoodieKey;
+import org.apache.hudi.common.model.HoodieLogFile;
 import org.apache.hudi.common.model.HoodieRecord;
 import org.apache.hudi.common.model.HoodieRecordGlobalLocation;
 import org.apache.hudi.common.table.TableSchemaResolver;
@@ -223,6 +224,7 @@ protected void loadRecords(String partitionPath) throws Exception {
 
         // load avro log records
         List<String> logPaths = fileSlice.getLogFiles()
+            .sorted(HoodieLogFile.getLogFileComparator())
             // filter out crushed files
             .filter(logFile -> isValidFile(logFile.getFileStatus()))
             .map(logFile -> logFile.getPath().toString())