This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 39717a8 [fix](load) Fix null column bug in load's mapping column
setting (#8625)
39717a8 is described below
commit 39717a85a27068237f0e5552484b619bedb35cc5
Author: HB <[email protected]>
AuthorDate: Mon Mar 28 10:08:00 2022 +0800
[fix](load) Fix null column bug in load's mapping column setting (#8625)
---
fe/fe-core/src/main/java/org/apache/doris/load/Load.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/Load.java
b/fe/fe-core/src/main/java/org/apache/doris/load/Load.java
index 76bff95..905f950 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/Load.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/Load.java
@@ -1028,6 +1028,9 @@ public class Load {
for (Entry<String, Pair<String, List<String>>> entry :
columnToHadoopFunction.entrySet()) {
String mappingColumnName = entry.getKey();
Column mappingColumn = tbl.getColumn(mappingColumnName);
+ if (mappingColumn == null) {
+ throw new DdlException("Mapping column is not in table.
column: " + mappingColumnName);
+ }
Pair<String, List<String>> function = entry.getValue();
try {
DataDescription.validateMappingFunction(function.first,
function.second, columnNameMap,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
