This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 313fab0802 [fix](mtmv) fix mtmv thread interruption issue (#18884)
313fab0802 is described below
commit 313fab08024b38dbc7264dadf3bb0e506ebc2261
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Fri Apr 21 22:27:13 2023 +0800
[fix](mtmv) fix mtmv thread interruption issue (#18884)
---
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java | 5 ++++-
1 file changed, 4 insertions(+), 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 0e27a4616f..44df43a8e3 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
@@ -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());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
