From d31f961e3ef179f26da092704ff5093927b91852 Mon Sep 17 00:00:00 2001 From: Molin Wang Date: Thu, 29 Dec 2022 17:02:19 +0800 Subject: [PATCH] [Fix-13247] [Master] Kill yarn job failed due to NPE exception (#13291) --- .../server/master/registry/MasterRegistryClient.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java index e670818f19..906952e709 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java @@ -483,6 +483,8 @@ public class MasterRegistryClient { .buildTaskInstanceRelatedInfo(taskInstance) .buildProcessInstanceRelatedInfo(processInstance) .create(); + taskExecutionContext.setProcessDefineCode(processInstance.getProcessDefinitionCode()); + taskExecutionContext.setProcessDefineVersion(processInstance.getProcessDefinitionVersion()); if (masterConfig.getMasterKillYarnJobWhenHandleFailOver() && !(taskInstance.isSubProcess()