[BugFix] Reset replication number for partition info to let the resto…

…red partition use the given value Signed-off-by: xiangguangyxg <xiangguangyxg@gmail.com>
StarRocks · Oct 24, 2024 · 7db18ee · 7db18ee
1 parent f15a530
commit 7db18ee
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/catalog/OlapTable.java b/fe/fe-core/src/main/java/com/starrocks/catalog/OlapTable.java
@@ -840,6 +840,8 @@ public Status resetIdsForRestore(GlobalStateMgr globalStateMgr, Database db, int
         Map<Long, Long> partitionOldIdToNewId = Maps.newHashMap();
         for (Long id : idToPartition.keySet()) {
             partitionOldIdToNewId.put(id, globalStateMgr.getNextId());
+            // reset replication number for partition info
+            partitionInfo.setReplicationNum(id, (short) restoreReplicationNum);
         }
 
         // reset partiton info