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>
This commit is contained in:
github-actions[bot]
2024-11-10 01:11:26 +08:00
committed by GitHub
parent 625a1ea6ad
commit fe1b8d44fd

View File

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