[doris] branch master updated: [fix](iceberg) fix error when query iceberg v2 format (#22182)

[mo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 20f180c4e1 [fix](iceberg) fix error when query iceberg v2 format (#22182)
20f180c4e1 is described below

commit 20f180c4e17c85b3b1d4deaa1dc9cb3b4bbc6396
Author: Mingyu Chen <mo...@163.com>
AuthorDate: Tue Jul 25 21:15:46 2023 +0800

    [fix](iceberg) fix error when query iceberg v2 format (#22182)
    
    This bug is introduced from #21771
    Missing fileType field of TFileScanRangeParams, so the delete file of iceberg v2 will be treated as local file
    and fail to read.
---
 .../java/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 d6ec536d5f..90f84deb94 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 @@ public abstract class FileQueryScanNode extends FileScanNode {
         } else if (locationType == TFileType.FILE_S3 && !params.isSetProperties()) {
             params.setProperties(locationProperties);
         }
+
+        if (!params.isSetFileType()) {
+            params.setFileType(locationType);
+        }
     }
 
     private TScanRangeLocations newLocations() {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org