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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
