This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 302b2bb3587 [improve](backup) Skip all backup/restore jobs if max
allowd option is set to 0 (#30677) (#30800)
302b2bb3587 is described below
commit 302b2bb358773a7804e44400d7a6fa6a427b19b0
Author: walter <[email protected]>
AuthorDate: Sun Feb 4 20:41:56 2024 +0800
[improve](backup) Skip all backup/restore jobs if max allowd option is set
to 0 (#30677) (#30800)
---
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 5279175fa00..c682262de02 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
@@ -471,6 +471,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]
