You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/01/27 01:14:06 UTC
(doris) 21/31: [pipeline](load) p0 load failed in pipeline stream load (#30438)
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 <ha...@hotmail.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org