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

…red partitions use the given value (#52263) Signed-off-by: xiangguangyxg <xiangguangyxg@gmail.com>
StarRocks · Oct 24, 2024 · 3cdcfe8 · 3cdcfe8
1 parent f91c1e5
commit 3cdcfe8
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