From 7db18ee4cb52f539f5a45c10960c24e71d2d49f0 Mon Sep 17 00:00:00 2001 From: xiangguangyxg Date: Thu, 24 Oct 2024 10:58:51 +0800 Subject: [PATCH] [BugFix] Reset replication number for partition info to let the restored partition use the given value Signed-off-by: xiangguangyxg --- fe/fe-core/src/main/java/com/starrocks/catalog/OlapTable.java | 2 ++ 1 file changed, 2 insertions(+) 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