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 ac394b3d7feca..56322952643eb 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 @@ -646,6 +646,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