From 87ed189ef5a7c23f31bbbbc34ea32e527f25c97c Mon Sep 17 00:00:00 2001 From: wenjun <861923274@qq.com> Date: Mon, 29 Mar 2021 10:15:18 +0800 Subject: [PATCH] [Improvement] print exception when task execute (#5159) --- .../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 b9ad8f37b6..d93e9e6813 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); } }