database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](tvf) cancel strict restrictions on tvf parameters (#15764)

Browse Source 
Cancel strict restrictions on tvf parameters.
This commit is contained in:
Ashin Gau
2023-01-10 22:40:19 +08:00
committed by GitHub
parent 79b24cdb1f
commit ab2e0fd397
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/tablefunction/HdfsTableValuedFunction.java
View File

@ -70,15 +70,13 @@ public class HdfsTableValuedFunction extends ExternalFileTableValuedFunction {
for (String key : params.keySet()) {
if (FILE_FORMAT_PROPERTIES.contains(key.toLowerCase())) {
fileFormatParams.put(key, params.get(key));
} else if (LOCATION_PROPERTIES.contains(key.toLowerCase()) || HADOOP_FS_NAME.equalsIgnoreCase(key)) {
} else {
// because HADOOP_FS_NAME contains upper and lower case
if (HADOOP_FS_NAME.equalsIgnoreCase(key)) {
locationProperties.put(HADOOP_FS_NAME, params.get(key));
} else {
locationProperties.put(key.toLowerCase(), params.get(key));
locationProperties.put(key, params.get(key));
}
} else {
throw new AnalysisException(key + " is invalid property");
}
}