[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.
This commit is contained in:
@ -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() {
|
||||
|
||||
Reference in New Issue
Block a user