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 8474703bee..40d5b99f34 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 @@ -158,8 +158,9 @@ public class StreamLoadPlanner { + col.getName()); } partialUpdateInputColumns.add(col.getName()); - if (destTable.hasSequenceCol() && destTable.getSequenceMapCol() != null - && destTable.getSequenceMapCol().equalsIgnoreCase(col.getName())) { + if (destTable.hasSequenceCol() && (taskInfo.hasSequenceCol() || ( + destTable.getSequenceMapCol() != null + && destTable.getSequenceMapCol().equalsIgnoreCase(col.getName())))) { partialUpdateInputColumns.add(Column.SEQUENCE_COL); } existInExpr = true;