[fix](delete) fix incorrect tablet schema of delete predicate rowset (#29536)

2024-01-05 18:26:30 +08:00
parent 2b3e75bb27
commit 67b9d38d83
1 changed files with 2 additions and 1 deletions
--- 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<TColumn> 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());
                }