From ab2e0fd39735fd0c737df895b6282a7ee3315991 Mon Sep 17 00:00:00 2001 From: Ashin Gau Date: Tue, 10 Jan 2023 22:40:19 +0800 Subject: [PATCH] [fix](tvf) cancel strict restrictions on tvf parameters (#15764) Cancel strict restrictions on tvf parameters. --- .../apache/doris/tablefunction/HdfsTableValuedFunction.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/HdfsTableValuedFunction.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/HdfsTableValuedFunction.java index c841bb3fad..542fc46bee 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/HdfsTableValuedFunction.java +++ b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/HdfsTableValuedFunction.java @@ -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"); } }