From 67b9d38d831ec95aee6762b4ab3e677c9def2615 Mon Sep 17 00:00:00 2001 From: Xin Liao Date: Fri, 5 Jan 2024 18:26:30 +0800 Subject: [PATCH] [fix](delete) fix incorrect tablet schema of delete predicate rowset (#29536) --- fe/fe-core/src/main/java/org/apache/doris/load/DeleteJob.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/DeleteJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/DeleteJob.java index eaa4395093..5bb07dd7b6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/DeleteJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/DeleteJob.java @@ -299,7 +299,8 @@ public class DeleteJob extends AbstractTxnStateChangeCallback implements DeleteJ int schemaHash = targetTbl.getSchemaHashByIndexId(indexId); List columnsDesc = Lists.newArrayList(); - for (Column column : targetTbl.getSchemaByIndexId(indexId)) { + // using to update schema of the rowset, so full columns should be included + for (Column column : targetTbl.getSchemaByIndexId(indexId, true)) { columnsDesc.add(column.toThrift()); }