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());