From fe1b8d44fdc58bbfcd40647202f47b3e90568c03 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Sun, 10 Nov 2024 01:11:26 +0800
Subject: [PATCH] branch-2.1: [fix](mtmv)Fix the problem where the job does not
 exist, which prevents the deletion of MTMV (#43325)

Cherry-picked from #43080

Co-authored-by: zhangdong <493738387@qq.com>
---
 .../src/main/java/org/apache/doris/mtmv/MTMVJobManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
index 8ffcea423d..2c03ad1617 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
@@ -130,7 +130,7 @@ public class MTMVJobManager implements MTMVHookService {
     public void dropMTMV(MTMV mtmv) throws DdlException {
         try {
             Env.getCurrentEnv().getJobManager()
-                    .unregisterJob(mtmv.getJobInfo().getJobName(), false);
+                    .unregisterJob(mtmv.getJobInfo().getJobName(), true);
         } catch (JobException e) {
             LOG.warn("drop mtmv job failed, mtmvName: {}", mtmv.getName(), e);
             throw new DdlException(e.getMessage());