From 7c4aaa9715cac6729c0809a92857b4aedbbbb24d Mon Sep 17 00:00:00 2001 From: Bo Cui Date: Tue, 21 Jun 2022 11:47:39 +0800 Subject: [PATCH] [HUDI-4270] Bootstrap op data loading missing (#5888) --- .../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 f0ef3bccb..10d46abc9 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.fs.FSUtils; 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 @@ public class BootstrapOperator> // 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())