[doris] branch master updated: [fix](spark load)use low case for expr (#24402)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei 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 8297da56ad [fix](spark load)use low case for expr (#24402)
8297da56ad is described below

commit 8297da56ad1bb541615b6afa8b105e4f70462824
Author: wuwenchi <wuwenchi...@hotmail.com>
AuthorDate: Fri Sep 15 17:30:03 2023 +0800

    [fix](spark load)use low case for expr (#24402)
    
    Use lowercase uniformly for expr.
---
 .../org/apache/doris/load/loadv2/SparkLoadPendingTask.java     | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadPendingTask.java
 
b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadPendingTask.java
index b9f361ddd8..8e9599f774 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadPendingTask.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadPendingTask.java
@@ -105,6 +105,16 @@ public class SparkLoadPendingTask extends LoadTask {
         this.transactionId = loadTaskCallback.getTransactionId();
         this.sparkLoadAppHandle = loadTaskCallback.getHandle();
         this.failMsg = new FailMsg(FailMsg.CancelType.ETL_SUBMIT_FAIL);
+        toLowCaseForFileGroups();
+    }
+
+    void toLowCaseForFileGroups() {
+        aggKeyToBrokerFileGroups.values().forEach(fgs -> {
+            fgs.forEach(fg -> {
+                fg.getColumnExprList()
+                        .forEach(expr -> 
expr.setColumnName(expr.getColumnName().toLowerCase(Locale.ROOT)));
+            });
+        });
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org