fix review2

job instanceof BackupJob
apache · Dec 8, 2024 · 30c6ec5 · 30c6ec5
1 parent 348b4b7
commit 30c6ec5
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -59,6 +59,7 @@
 import org.apache.doris.analysis.TableRef;
 import org.apache.doris.analysis.TruncateTableStmt;
 import org.apache.doris.analysis.TypeDef;
+import org.apache.doris.backup.AbstractJob;
 import org.apache.doris.backup.BackupJob;
 import org.apache.doris.backup.RestoreJob;
 import org.apache.doris.catalog.BinlogConfig;
@@ -890,9 +891,11 @@ public void checkBuckupRunning(Database db, OlapTable olapTable) throws DdlExcep
             return;
         }
 
-        BackupJob backupJob = (BackupJob) Env.getCurrentEnv().getBackupHandler().getJob(db.getId());
-        if (backupJob != null && !backupJob.isDone()
-                && (olapTable == null || backupJob.getBackupMeta().getTable(olapTable.getId()) != null)) {
+        AbstractJob job = Env.getCurrentEnv().getBackupHandler().getJob(db.getId());
+        if (job != null job instanceof BackupJob) {
+            BackupJob backupJob = (BackupJob) job;
+            if (backupJob.isDone()
+                    && (olapTable == null || backupJob.getBackupMeta().getTable(olapTable.getId()) != null)) {
             LOG.warn("Backup is running on this db {} ", db.getName());
             ErrorReport.reportDdlException(ErrorCode.ERR_COMMON_ERROR, "Backup is running on this db: " + db.getName());
         }