From 05b6834051807f5097e6de767ac1e4d4485598cd Mon Sep 17 00:00:00 2001 From: Bo Date: Thu, 16 Jun 2022 18:42:44 +0800 Subject: [PATCH] [HUDI-4270] Bootstrap op data loading missing --- .../java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java index f0ef3bccb7fa..10d46abc94ca 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java +++ b/hudi-flink-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 logPaths = fileSlice.getLogFiles() + .sorted(HoodieLogFile.getLogFileComparator()) // filter out crushed files .filter(logFile -> isValidFile(logFile.getFileStatus())) .map(logFile -> logFile.getPath().toString())