[pipeline](load) p0 load failed in pipeline stream load (#30438)

This commit is contained in:
HappenLee
2024-01-26 21:08:43 +08:00
committed by yiguolei
parent f1a135619c
commit 1fdb323154

View File

@ -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())) {