[doris] branch master updated: [fix](mtmv) fix mtmv thread interruption issue (#18884)

[yi...@apache.org]

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 <mo...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org