From 3747029cc06cef2c3dd5063b3dc303585627400b Mon Sep 17 00:00:00 2001 From: fuchanghai <33984497+fuchanghai@users.noreply.github.com> Date: Tue, 22 Nov 2022 15:07:50 +0800 Subject: [PATCH] [fix-#12932] when subprocess's processInstance is fail,not notify parent processInstance (#12933) --- .../server/master/runner/WorkflowExecuteThreadPool.java | 1 + 1 file changed, 1 insertion(+) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java index 20fe003fc3..fd368d55bb 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java @@ -122,6 +122,7 @@ public class WorkflowExecuteThreadPool extends ThreadPoolTaskExecutor { LoggerUtils.setWorkflowInstanceIdMDC(processInstanceId); try { logger.error("Workflow instance events handle failed", ex); + notifyProcessChanged(workflowExecuteThread.getProcessInstance()); multiThreadFilterMap.remove(workflowExecuteThread.getKey()); } finally { LoggerUtils.removeWorkflowInstanceIdMDC();