[fix][hudi] use lowerCase to get hudi fileFormatType (#9873)

use lowerCase of inputFormatName to get hudi fileFormatType
apache · Jun 9, 2022 · 050cbba · 050cbba
1 parent 19bc14c
commit 050cbba
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/HudiScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/HudiScanNode.java
@@ -299,13 +299,13 @@ protected void buildScanRange() throws UserException, IOException {
         hdfsParams.setFsName(fsName);
         Log.debug("Hudi path's host is " + fsName);
 
-        TFileFormatType formatType = null;
-        if (this.inputFormatName.toUpperCase(Locale.ROOT).contains("parquet")) {
-            formatType = TFileFormatType.FORMAT_PARQUET;
-        } else if (this.inputFormatName.toUpperCase(Locale.ROOT).contains("orc")) {
-            formatType = TFileFormatType.FORMAT_ORC;
+        TFileFormatType fileFormatType = null;
+        if (this.inputFormatName.toLowerCase().contains("parquet")) {
+            fileFormatType = TFileFormatType.FORMAT_PARQUET;
+        } else if (this.inputFormatName.toLowerCase(Locale.ROOT).contains("orc")) {
+            fileFormatType = TFileFormatType.FORMAT_ORC;
         } else {
-            throw new UserException("unsupported hudi table type [" + this.inputFormatName + "].");
+            throw new UserException("Unsupported hudi table format [" + this.inputFormatName + "].");
         }
 
         ParamCreateContext context = getParamCreateContexts().get(0);
@@ -317,7 +317,7 @@ protected void buildScanRange() throws UserException, IOException {
                     getPartitionKeys());
             int numberOfColumnsFromFile = context.slotDescByName.size() - partitionValuesFromPath.size();
 
-            TBrokerRangeDesc rangeDesc = createBrokerRangeDesc(fileSplit, formatType,
+            TBrokerRangeDesc rangeDesc = createBrokerRangeDesc(fileSplit, fileFormatType,
                     partitionValuesFromPath, numberOfColumnsFromFile, brokerDesc);
             rangeDesc.setHdfsParams(hdfsParams);
             rangeDesc.setReadByColumnDef(true);