From 0560dab66c73cc2b4f16e64870f2a3e3df622005 Mon Sep 17 00:00:00 2001 From: xiangguangyxg <110401425+xiangguangyxg@users.noreply.github.com> Date: Thu, 24 Oct 2024 14:17:11 +0800 Subject: [PATCH] [BugFix] Reset replication number for partition info to let the restored partitions use the given value (#52263) Signed-off-by: xiangguangyxg (cherry picked from commit 3cdcfe8cdc9881d1a1e53974f182308804f68a50) --- 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 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