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

[case](mtmv) MTMV hive case (#30930)

Browse Source
This commit is contained in:
zhangdong
2024-02-07 17:18:24 +08:00
committed by yiguolei
parent 1d10132aa1
commit de1724ab6a
6 changed files with 307 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVPartitionUtil.java
View File

@ -90,8 +90,8 @@ public class MTMVPartitionUtil {
*/
public static void alignMvPartition(MTMV mtmv, MTMVRelatedTableIf relatedTable)
throws DdlException, AnalysisException {
Map<Long, PartitionItem> relatedTableItems = relatedTable.getPartitionItems();
Map<Long, PartitionItem> mtmvItems = mtmv.getPartitionItems();
Map<Long, PartitionItem> relatedTableItems = Maps.newHashMap(relatedTable.getPartitionItems());
Map<Long, PartitionItem> mtmvItems = Maps.newHashMap(mtmv.getPartitionItems());
// drop partition of mtmv
for (Entry<Long, PartitionItem> entry : mtmvItems.entrySet()) {
long partitionId = getExistPartitionId(entry.getValue(), relatedTableItems);