[incubator-doris] 10/20: [fix](load) Fix null column bug in load's mapping column setting (#8625)

[morningman]

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

morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git

commit ca1974f9bd4da10986480321ae22310b05a62915
Author: HB <137497...@qq.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org