From 4e57f45d8e7cd3cfbe8279aef5578a0dad17f1be Mon Sep 17 00:00:00 2001 From: zhannngchen <48427519+zhannngchen@users.noreply.github.com> Date: Wed, 26 Jul 2023 18:22:43 +0800 Subject: [PATCH] [fix](partial-update) sequence column not updated if using function_column.sequence_type (#22250) --- .../java/org/apache/doris/planner/StreamLoadPlanner.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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;