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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
