This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit c8b0840e6ceb78827d57f1e08d6e7d96f9ec5b7a Author: walter <[email protected]> AuthorDate: Thu Feb 1 18:55:12 2024 +0800 [improve](backup) Skip all backup/restore jobs if max allowd option is set to 0 (#30677) If there are too many backup/restore jobs, it may cause OOM. This PR allows the user to skip all backup/restore jobs if max_backup_restore_job_num_per_db is set to 0. --- fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 7c0485228f7..a4332e054cf 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<AbstractJob> jobs = dbIdToBackupOrRestoreJobs.computeIfAbsent(dbId, k -> Lists.newLinkedList()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
