From 25f18e8f26a9aef026c3cfa9866c0f4f474611d5 Mon Sep 17 00:00:00 2001
From: morningman <morningman@163.com>
Date: Tue, 25 Jul 2023 00:10:46 +0800
Subject: [PATCH] [fix](iceberg) fix error when query iceberg v2 format

---
 .../org/apache/doris/planner/external/FileQueryScanNode.java  | 4 ++++
 1 file changed, 4 insertions(+)

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() {