database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[branch-2.1] Picks "[Fix](partial update) Fix partial update failed when merge_type=MERGE #40730" (#40951)

Browse Source 
picks https://github.com/apache/doris/pull/40730
This commit is contained in:
bobhan1
2024-09-20 00:02:17 +08:00
committed by GitHub
parent 8b1906be81
commit 64880a10d6
11 changed files with 554 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
View File

@ -189,7 +189,8 @@ public class StreamLoadPlanner {
}
}
}
if (taskInfo.getMergeType() == LoadTask.MergeType.DELETE) {
if (taskInfo.getMergeType() == LoadTask.MergeType.DELETE
|| taskInfo.getMergeType() == LoadTask.MergeType.MERGE) {
partialUpdateInputColumns.add(Column.DELETE_SIGN);
}
}
@ -440,7 +441,8 @@ public class StreamLoadPlanner {
}
}
}
if (taskInfo.getMergeType() == LoadTask.MergeType.DELETE) {
if (taskInfo.getMergeType() == LoadTask.MergeType.DELETE
|| taskInfo.getMergeType() == LoadTask.MergeType.MERGE) {
partialUpdateInputColumns.add(Column.DELETE_SIGN);
}
}