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); } }