[fix](hudi) fix wrong schema when query hudi table on obs #26789 (#26791

)
apache · Nov 11, 2023 · 5188320 · 5188320
1 parent 562a72f
commit 5188320
Showing 1 changed file with 4 additions and 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
@@ -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<Split> 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 {