From 4362fb8448fecdd1073ced8e268b629de269a649 Mon Sep 17 00:00:00 2001 From: Wenjun Ruan Date: Sat, 13 Aug 2022 22:01:39 +0800 Subject: [PATCH] If the task processor is not found need to throw error rather than exception (#11461) --- .../server/master/event/TaskStateEventHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java index 07e6ab546c..aab5d2d6a2 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java @@ -82,7 +82,7 @@ public class TaskStateEventHandler implements StateEventHandler { } return true; } - throw new StateEventHandleException( + throw new StateEventHandleError( "Task state event handle error, due to the task is not in activeTaskProcessorMaps"); }