[BugFix][Admin]Fix dolphinscheduler calls dinky tasks and concurrent … (

#4010) Co-authored-by: 黄苏苏 <[email protected]>
DataLinkDC · Dec 6, 2024 · 75513e5 · 75513e5
1 parent 19a061c
commit 75513e5
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/service/task/BaseTask.java b/dinky-admin/src/main/java/org/dinky/service/task/BaseTask.java
@@ -39,6 +39,10 @@
 
 @AllArgsConstructor
 public abstract class BaseTask {
+
+    private static final Set<Class<?>> taskRegistry =
+            ClassUtil.scanPackageBySuper(BaseTask.class.getPackage().getName(), BaseTask.class);
+
     final TaskDTO task;
 
     public abstract JobResult execute() throws Exception;
@@ -58,9 +62,7 @@ public ObjectNode getJobPlan() throws NotSupportExplainExcepition {
     }
 
     public static BaseTask getTask(TaskDTO taskDTO) {
-        Set<Class<?>> classes =
-                ClassUtil.scanPackageBySuper(BaseTask.class.getPackage().getName(), BaseTask.class);
-        for (Class<?> clazz : classes) {
+        for (Class<?> clazz : taskRegistry) {
             SupportDialect annotation = clazz.getAnnotation(SupportDialect.class);
             if (annotation != null) {
                 for (Dialect dialect : annotation.value()) {