From e2557096b6a5930296560d0f9a70b7146089eb35 Mon Sep 17 00:00:00 2001 From: morningman Date: Fri, 10 Nov 2023 22:29:07 +0800 Subject: [PATCH] 1 --- .../org/apache/doris/planner/external/hudi/HudiScanNode.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiScanNode.java index b0306ab19c68e1..4b8b5dcef0d6a9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiScanNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiScanNode.java @@ -26,6 +26,7 @@ import org.apache.doris.catalog.external.ExternalTable; import org.apache.doris.common.AnalysisException; import org.apache.doris.common.UserException; +import org.apache.doris.common.util.S3Util; import org.apache.doris.datasource.hive.HivePartition; import org.apache.doris.planner.ListPartitionPrunerV2; import org.apache.doris.planner.PlanNodeId; @@ -42,6 +43,7 @@ import org.apache.doris.thrift.TTableFormatFileDesc; import com.google.common.collect.Lists; +import com.google.common.collect.Maps; import org.apache.avro.Schema; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.Path; @@ -284,7 +286,8 @@ public List getSplits() throws UserException { noLogsSplitNum.incrementAndGet(); String filePath = baseFile.getPath(); long fileSize = baseFile.getFileSize(); - splits.add(new FileSplit(new Path(filePath), 0, fileSize, fileSize, new String[0], + splits.add(new FileSplit(S3Util.toScanRangeLocation(filePath, Maps.newHashMap()), + 0, fileSize, fileSize, new String[0], partition.getPartitionValues())); }); } else {