diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java index 9d8ee1bcb750b9..2874dc900c8be0 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java @@ -250,8 +250,9 @@ public RestoreJob(String label, String backupTs, long dbId, String dbName, Backu this.metaVersion = metaVersion; this.reserveReplica = reserveReplica; this.reserveColocate = reserveColocate; - // if backup snapshot is come from a cluster with force replication allocation, ignore the origin allocation - if (jobInfo.isForceReplicationAllocation) { + // if is cloud mode or backup snapshot is come from a cluster with force replication allocation, + // ignore the origin allocation + if (Config.isCloudMode() || jobInfo.isForceReplicationAllocation) { this.reserveReplica = false; } this.reserveDynamicPartitionEnable = reserveDynamicPartitionEnable;