From 68874b97fbba3d7709810377718532e2bc16a522 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Tue, 26 Dec 2023 18:22:41 +0800
Subject: [PATCH] add log for resolve pending task

---
 .../org/apache/doris/job/scheduler/JobScheduler.java     | 9 ++++++---
 .../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 08bbbb6dbaba9a..03a7792cc502f1 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 void schedulerInstantJob(T job, TaskType taskType, C context) {
             }
             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 29f60841f31cfd..a299f0a01d49f0 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);