[incubator-dolphinscheduler] branch dev updated: [Improvement] print exception when task execute (#5159)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 87ed189  [Improvement] print exception when task execute (#5159)
87ed189 is described below

commit 87ed189ef5a7c23f31bbbbc34ea32e527f25c97c
Author: wenjun <861923...@qq.com>
AuthorDate: Mon Mar 29 10:15:18 2021 +0800

    [Improvement] print exception when task execute (#5159)
---
 .../dolphinscheduler/server/master/runner/MasterExecThread.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 b9ad8f3..d93e9e6 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);
         }
     }