Parcourir la source

refactor-worker merge to dev bug fix

qiaozhanwei il y a 5 ans
Parent
commit
b45e70f8fa

+ 1 - 0
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumer.java

@@ -191,6 +191,7 @@ public class TaskPriorityQueueConsumer extends Thread{
                 .buildSQLTaskRelatedInfo(sqlTaskExecutionContext)
                 .buildDataxTaskRelatedInfo(dataxTaskExecutionContext)
                 .buildProcedureTaskRelatedInfo(procedureTaskExecutionContext)
+                .buildSqoopTaskRelatedInfo(sqoopTaskExecutionContext)
                 .create();
     }