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()); }