[dolphinscheduler] branch 2.0.1-prepare updated: fix waterdrop task plugin (#7216)

[ki...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a commit to branch 2.0.1-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/2.0.1-prepare by this push:
     new b4c422e  fix waterdrop task plugin (#7216)
b4c422e is described below

commit b4c422e977c4bc4bbbfd513281a221790274b875
Author: Kerwin <37...@users.noreply.github.com>
AuthorDate: Mon Dec 6 17:42:41 2021 +0800

    fix waterdrop task plugin (#7216)
---
 .../dolphinscheduler/server/worker/plugin/TaskPluginManager.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/plugin/TaskPluginManager.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/plugin/TaskPluginManager.java
index 21ab22e..7c35b13 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/plugin/TaskPluginManager.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/plugin/TaskPluginManager.java
@@ -18,6 +18,7 @@
 package org.apache.dolphinscheduler.server.worker.plugin;
 
 import org.apache.dolphinscheduler.common.enums.PluginType;
+import org.apache.dolphinscheduler.common.enums.TaskType;
 import org.apache.dolphinscheduler.dao.PluginDao;
 import org.apache.dolphinscheduler.dao.entity.PluginDefine;
 import org.apache.dolphinscheduler.spi.params.PluginParamsTransfer;
@@ -81,5 +82,9 @@ public class TaskPluginManager {
                 throw new RuntimeException("Failed to update task plugin: " + name);
             }
         });
+
+        // put WATERDROP task
+        taskChannelMap.put(TaskType.WATERDROP.getDesc(), taskChannelMap.get(TaskType.SHELL.getDesc()));
+
     }
 }