This is an automated email from the ASF dual-hosted git repository.
morningman 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 6ed09c3f46a [fix](mtmv)add log for resolve pending task (#29078)
6ed09c3f46a is described below
commit 6ed09c3f46a2ba3e75452b3369e1bdcfc71d9d4b
Author: zhangdong <493738...@qq.com>
AuthorDate: Wed Dec 27 12:36:17 2023 +0800
[fix](mtmv)add log for resolve pending task (#29078)
---
.../main/java/org/apache/doris/job/scheduler/JobScheduler.java | 9 ++++++---
.../main/groovy/org/apache/doris/regression/suite/Suite.groovy | 4 ++--
2 files changed, 8 insertions(+), 5 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/job/scheduler/JobScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/job/scheduler/JobScheduler.java
index 08bbbb6dbab..03a7792cc50 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/scheduler/JobScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/scheduler/JobScheduler.java
@@ -161,9 +161,12 @@ public class JobScheduler<T extends AbstractJob<?, C>, C>
implements Closeable {
}
return;
}
- tasks.forEach(task ->
taskDisruptorGroupManager.dispatchInstantTask(task, job.getJobType(),
- job.getJobConfig()));
-
+ tasks.forEach(task -> {
+ taskDisruptorGroupManager.dispatchInstantTask(task,
job.getJobType(),
+ job.getJobConfig());
+ log.info("dispatch instant job, job id is {}, job name is {}, task
id is {}", job.getJobId(),
+ job.getJobName(), task.getTaskId());
+ });
}
/**
diff --git
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
index 29f60841f31..a299f0a01d4 100644
---
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
+++
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -845,7 +845,7 @@ class Suite implements GroovyInterceptable {
void waitingMTMVTaskFinished(String jobName) {
Thread.sleep(2000);
- String showTasks = "select Status from tasks('type'='mv') where
JobName = '${jobName}'"
+ String showTasks = "select TaskId,JobId,JobName,MvId,Status from
tasks('type'='mv') where JobName = '${jobName}'"
String status = "NULL"
List<List<Object>> result
long startTime = System.currentTimeMillis()
@@ -854,7 +854,7 @@ class Suite implements GroovyInterceptable {
result = sql(showTasks)
logger.info("result: " + result.toString())
if (!result.isEmpty()) {
- status = result.last().get(0)
+ status = result.last().get(4)
}
logger.info("The state of ${showTasks} is ${status}")
Thread.sleep(1000);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
