[fix](iceberg) fix error when query iceberg v2 format

morningman · Jul 24, 2023 · 25f18e8 · 25f18e8
1 parent 752cec9
commit 25f18e8
Showing 1 changed file with 4 additions and 0 deletions.
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
@@ -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() {