This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 8cc4b1baa956bde37412d8c99b5260f020b6a141 Author: bobhan1 <[email protected]> AuthorDate: Wed Aug 16 14:20:39 2023 +0800 [fix](partial update)allow delete sign column in partial update in planForPipeline (#23034) --- .../src/main/java/org/apache/doris/planner/StreamLoadPlanner.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 675d2b42d3..702dde966c 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 @@ -363,9 +363,9 @@ public class StreamLoadPlanner { for (ImportColumnDesc importColumnDesc : taskInfo.getColumnExprDescs().descs) { if (importColumnDesc.getColumnName() != null && importColumnDesc.getColumnName().equals(col.getName())) { - if (!col.isVisible()) { - throw new UserException("Partial update should not include invisible column: " - + col.getName()); + if (!col.isVisible() && !Column.DELETE_SIGN.equals(col.getName())) { + throw new UserException("Partial update should not include invisible column except" + + " delete sign column: " + col.getName()); } partialUpdateInputColumns.add(col.getName()); if (destTable.hasSequenceCol() && (taskInfo.hasSequenceCol() || ( --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
