diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/executor/TimerJobSchedulerTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/executor/TimerJobSchedulerTask.java index 25bbccf3fa2fa6..50793d80296915 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/executor/TimerJobSchedulerTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/executor/TimerJobSchedulerTask.java @@ -45,7 +45,7 @@ public void run(Timeout timeout) { return; } if (!dispatchDisruptor.publishEvent(this.job)) { - log.warn("dispatch timer job failed, job id is {}, job name is {}", + log.warn("dispatch timer job failed, queue maybe full. job id is {}, job name is {}", this.job.getJobId(), this.job.getJobName()); } } catch (Exception e) { 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 862b85597cdc3a..c9bc77ff9b8166 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 @@ -168,7 +168,7 @@ public void schedulerInstantJob(T job, TaskType taskType, C context) throws JobE for (AbstractTask task : tasks) { if (!taskDisruptorGroupManager.dispatchInstantTask(task, job.getJobType(), job.getJobConfig())) { - throw new JobException("dispatch instant task failed, job id is " + throw new JobException("dispatch instant task failed, queue maybe full, job id is " + job.getJobId() + ", task id is " + task.getTaskId()); } log.info("dispatch instant job, job id is {}, job name is {}, task id is {}", job.getJobId(),