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 index 6ecb826eb976f..4098250970e85 100644 --- 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 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