This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 1fdb32315421c83e0d3d6fcbbf1f1445bfbe1771 Author: HappenLee <[email protected]> AuthorDate: Fri Jan 26 21:08:43 2024 +0800 [pipeline](load) p0 load failed in pipeline stream load (#30438) --- .../src/main/java/org/apache/doris/planner/StreamLoadPlanner.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java index ca4e3de9f58..346a7528606 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java @@ -377,6 +377,9 @@ public class StreamLoadPlanner { if (isPartialUpdate) { for (Column col : destTable.getFullSchema()) { boolean existInExpr = false; + if (col.hasOnUpdateDefaultValue()) { + partialUpdateInputColumns.add(col.getName()); + } for (ImportColumnDesc importColumnDesc : taskInfo.getColumnExprDescs().descs) { if (importColumnDesc.getColumnName() != null && importColumnDesc.getColumnName().equals(col.getName())) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
