[fix](mtmv)add log for resolve pending task (#29078)

2023-12-27 12:36:17 +08:00
parent 0b5fe681e4
commit 6ed09c3f46
2 changed files with 8 additions and 5 deletions
--- 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());
+        });
    }

    /**