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
index 3b2a95544a36f..40d48991cc925 100644
--- 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()));