diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java index b9ad8f37b6988147ddc41fdc98890df7b93507b9..d93e9e68130e4a1cefd03f570e083fbb43ab58e4 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java @@ -887,7 +887,7 @@ public class MasterExecThread implements Runnable { try { readyToSubmitTaskQueue.put(taskInstance); } catch (Exception e) { - logger.error("add task instance to readyToSubmitTaskQueue error"); + logger.error("add task instance to readyToSubmitTaskQueue error, taskName: {}", taskInstance.getName(), e); } } @@ -901,7 +901,7 @@ public class MasterExecThread implements Runnable { try { readyToSubmitTaskQueue.remove(taskInstance); } catch (Exception e) { - logger.error("remove task instance from readyToSubmitTaskQueue error"); + logger.error("remove task instance from readyToSubmitTaskQueue error, taskName: {}", taskInstance.getName(), e); } }