diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileQueryScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileQueryScanNode.java index d6ec536d5f5449..90f84deb946c46 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileQueryScanNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileQueryScanNode.java @@ -363,6 +363,10 @@ private void setLocationPropertiesIfNecessary(TFileType locationType, FileSplit } else if (locationType == TFileType.FILE_S3 && !params.isSetProperties()) { params.setProperties(locationProperties); } + + if (!params.isSetFileType()) { + params.setFileType(locationType); + } } private TScanRangeLocations newLocations() {