From 27291d311221712a4f931861c7db0e3f5cddb798 Mon Sep 17 00:00:00 2001
From: insist777 <84278047+insist777@users.noreply.github.com>
Date: Fri, 19 Aug 2022 11:54:09 +0800
Subject: [PATCH] Update TaskProcessorFactory.java

---
 .../server/master/runner/task/TaskProcessorFactory.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/TaskProcessorFactory.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/TaskProcessorFactory.java
index 90f5ea842..470920f35 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/TaskProcessorFactory.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/TaskProcessorFactory.java
@@ -47,7 +47,7 @@ public final class TaskProcessorFactory {
     static {
         for (ITaskProcessor iTaskProcessor : ServiceLoader.load(ITaskProcessor.class)) {
             try {
-              if (PROCESS_MAP.get(iTaskProcessor.getType()) == null )
+              if (!PROCESS_MAP.containsKey(iTaskProcessor.getType()))
                   PROCESS_MAP.put(iTaskProcessor.getType(), (Constructor<ITaskProcessor>) iTaskProcessor.getClass().getConstructor());
             } catch (NoSuchMethodException e) {
                 throw new IllegalArgumentException("The task processor should has a no args constructor", e);
-- 
GitLab