diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
index bc524e28f9..6b4b799ef9 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
@@ -134,9 +134,9 @@ public class MasterBaseTaskExecThread implements Callable<Boolean> {
                     return task;
                 }
                 if(!submitDB){
-                    logger.error("task commit to db failed , task has already retry {} times, please check the database", retryTimes);
+                    logger.error("task commit to db failed , taskId {} has already retry {} times, please check the database", taskInstance.getId(), retryTimes);
                 }else if(!submitQueue){
-                    logger.error("task commit to queue failed , task has already retry {} times, please check the database", retryTimes);
+                    logger.error("task commit to queue failed , taskId {} has already retry {} times, please check the queue", taskInstance.getId(), retryTimes);
                 }
                 Thread.sleep(commitRetryInterval);
             } catch (Exception e) {
diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java
index 16bb16de38..7d10591e0d 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java
@@ -75,6 +75,7 @@ public class MasterTaskExecThread extends MasterBaseTaskExecThread {
         Boolean result = false;
         this.taskInstance = submit();
         if(this.taskInstance == null){
+            logger.error("submit task instance to mysql and queue failed , please check and fix it");
             return result;
         }
         if(!this.taskInstance.getState().typeIsFinished()) {