This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 1a8c34748b9 [branch-1.2](backup) return if status not ok to reduce
summit job #26940 (#27803)
1a8c34748b9 is described below
commit 1a8c34748b9e60499bc2ba8fc47c6a8c022f9674
Author: xueweizhang <[email protected]>
AuthorDate: Wed Dec 6 23:43:03 2023 +0800
[branch-1.2](backup) return if status not ok to reduce summit job #26940
(#27803)
bp #26940
Signed-off-by: nextdreamblue <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/backup/BackupJob.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJob.java
b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJob.java
index b15af91cead..999e35412ae 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJob.java
@@ -368,8 +368,14 @@ public class BackupJob extends AbstractJob {
switch (tbl.getType()) {
case OLAP:
checkOlapTable((OlapTable) tbl, tableRef);
+ if (!status.ok()) {
+ return;
+ }
if (getContent() == BackupContent.ALL) {
prepareSnapshotTaskForOlapTable((OlapTable) tbl,
tableRef, batchTask);
+ if (!status.ok()) {
+ return;
+ }
}
break;
case VIEW:
@@ -396,6 +402,9 @@ public class BackupJob extends AbstractJob {
// copy all related schema at this moment
prepareBackupMeta(db);
+ if (!status.ok()) {
+ return;
+ }
// send tasks
for (AgentTask task : batchTask.getAllTasks()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
