You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2023/12/25 16:29:35 UTC
(doris) branch master updated: [fix](mtmv)add log for resolve pending task (#28999)
This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 2aea47c0a93 [fix](mtmv)add log for resolve pending task (#28999)
2aea47c0a93 is described below
commit 2aea47c0a9383c1c981cbf2cb7dd72bce2bfb3ec
Author: zhangdong <49...@qq.com>
AuthorDate: Tue Dec 26 00:29:28 2023 +0800
[fix](mtmv)add log for resolve pending task (#28999)
* add lock for resolve pending task
* add lock for resolve pending task
---
.../main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
index ab9b6f9fa94..7c11f0549ad 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
@@ -135,6 +135,7 @@ public class MTMVTask extends AbstractTask {
@Override
public void run() throws JobException {
+ LOG.info("mtmv task run, taskId: {}", super.getTaskId());
try {
ConnectContext ctx = MTMVPlanUtil.createMTMVContext(mtmv);
// Every time a task is run, the relation is regenerated because baseTables and baseViews may change,
@@ -185,18 +186,21 @@ public class MTMVTask extends AbstractTask {
@Override
public synchronized void onFail() throws JobException {
+ LOG.info("mtmv task onFail, taskId: {}", super.getTaskId());
super.onFail();
after();
}
@Override
public synchronized void onSuccess() throws JobException {
+ LOG.info("mtmv task onSuccess, taskId: {}", super.getTaskId());
super.onSuccess();
after();
}
@Override
public synchronized void cancel() throws JobException {
+ LOG.info("mtmv task cancel, taskId: {}", super.getTaskId());
super.cancel();
if (executor != null) {
executor.cancel();
@@ -206,6 +210,7 @@ public class MTMVTask extends AbstractTask {
@Override
public void before() throws JobException {
+ LOG.info("mtmv task before, taskId: {}", super.getTaskId());
super.before();
try {
Database db = Env.getCurrentInternalCatalog().getDbOrDdlException(dbId);
@@ -222,12 +227,16 @@ public class MTMVTask extends AbstractTask {
@Override
public void runTask() throws JobException {
+ LOG.info("mtmv task runTask, taskId: {}", super.getTaskId());
MTMVJob job = (MTMVJob) getJobOrJobException();
try {
+ LOG.info("mtmv task get writeLock start, taskId: {}", super.getTaskId());
job.writeLock();
+ LOG.info("mtmv task get writeLock end, taskId: {}", super.getTaskId());
super.runTask();
} finally {
job.writeUnlock();
+ LOG.info("mtmv task release writeLock, taskId: {}", super.getTaskId());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org