database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](mtmv) fix mtmv thread interruption issue (#18884)

Browse Source
This commit is contained in:
Mingyu Chen
2023-04-21 22:27:13 +08:00
committed by GitHub
parent 425101bf53
commit 313fab0802
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
View File

@ -306,7 +306,10 @@ public class MTMVJobManager {
LOG.warn("fail to obtain scheduled info for job [{}]", job.getName());
return true;
}
boolean isCancel = future.cancel(true);
// MUST not set true for "mayInterruptIfRunning".
// Because this thread may doing bdbje write operation, it is interrupted,
// FE may exit due to bdbje write failure.
boolean isCancel = future.cancel(false);
if (!isCancel) {
LOG.warn("fail to cancel scheduler for job [{}]", job.getName());
}