diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java index 7c0485228f..a4332e054c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java @@ -516,6 +516,12 @@ public class BackupHandler extends MasterDaemon implements Writable { } private void addBackupOrRestoreJob(long dbId, AbstractJob job) { + // If there are too many backup/restore jobs, it may cause OOM. If the job num option is set to 0, + // skip all backup/restore jobs. + if (Config.max_backup_restore_job_num_per_db <= 0) { + return; + } + jobLock.lock(); try { Deque jobs = dbIdToBackupOrRestoreJobs.computeIfAbsent(dbId, k -> Lists.newLinkedList());