[fix-#12932] when subprocess's processInstance is fail,not notify par…

…ent processInstance (#12933)
apache · Nov 22, 2022 · 3747029 · 3747029
1 parent d09e02e
commit 3747029
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java b/...main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java
@@ -122,6 +122,7 @@ public void onFailure(Throwable ex) {
                 LoggerUtils.setWorkflowInstanceIdMDC(processInstanceId);
                 try {
                     logger.error("Workflow instance events handle failed", ex);
+                    notifyProcessChanged(workflowExecuteThread.getProcessInstance());
                     multiThreadFilterMap.remove(workflowExecuteThread.getKey());
                 } finally {
                     LoggerUtils.removeWorkflowInstanceIdMDC();