From 9e0991145e5de196f30f2c7c080a6ad48fdf2bb4 Mon Sep 17 00:00:00 2001 From: Aaron Wang Date: Sat, 27 May 2023 17:39:03 +0800 Subject: [PATCH] [Improvement-14146][K8S Task] print complete error logs in task log file (#14147) --- .../dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java index c4df23cadf..6f08dde14d 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java @@ -48,8 +48,9 @@ public abstract class AbstractK8sTask extends AbstractRemoteTask { setExitStatusCode(response.getExitStatusCode()); setAppIds(response.getAppIds()); } catch (Exception e) { + log.error("k8s task submit failed with error", e); exitStatusCode = -1; - throw new TaskException("k8s process failure", e); + throw new TaskException("Execute k8s task error", e); } }