fix bugs

Signed-off-by: shuming.li <[email protected]>
LiShuMing · Dec 10, 2024 · dc535c3 · dc535c3
1 parent de2782c
commit dc535c3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/catalog/mv/MVTimelinessArbiter.java b/fe/fe-core/src/main/java/com/starrocks/catalog/mv/MVTimelinessArbiter.java
@@ -192,7 +192,7 @@ protected void collectExtraBaseTableChangedPartitions(Map<Table, MvBaseTableUpda
         for (Map.Entry<Table, Map<String, PCell>> entry : extraChangedPartitions.entrySet()) {
             Table baseTable = entry.getKey();
             Preconditions.checkState(basePartitionNameToRangeMap.containsKey(baseTable));
-            Map<String, PCell> refBaseTablePartitionRangeMap = (Map<String, PCell>) basePartitionNameToRangeMap.get(baseTable);
+            Map<String, PCell> refBaseTablePartitionRangeMap = basePartitionNameToRangeMap.get(baseTable);
             Map<String, PCell> basePartitionNameToRanges = entry.getValue();
             basePartitionNameToRanges.entrySet().forEach(e ->
                     refBaseTablePartitionRangeMap.put(e.getKey(), e.getValue()));