diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/executor/TaskProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/job/executor/TaskProcessor.java
index 61706b261d0074..d9d3f25dcd8a80 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/executor/TaskProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/executor/TaskProcessor.java
@@ -45,7 +45,7 @@ public  TaskProcessor(int numberOfThreads, int queueSize, ThreadFactory threadFa
 
     public boolean addTask(AbstractTask task) {
         try {
-            executor.execute(() -> runTask(task)); // 直接提交任务
+            executor.execute(() -> runTask(task));
             log.info("Add task to executor, task id: {}", task.getTaskId());
             return true;
         } catch (RejectedExecutionException e) {