diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java index f03a97881f..6f9a99e11d 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java @@ -1142,7 +1142,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ } /** - * get complement dependent process definition list + * get complement dependent online process definition list */ private List getComplementDependentDefinitionList(long processDefinitionCode, CycleEnum processDefinitionCycle, diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml index 2689b6d50f..9eac0d0a12 100644 --- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml +++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml @@ -161,6 +161,7 @@ AND a.task_params LIKE concat('%', #{code}, '%') AND a.task_type = 'DEPENDENT' + AND c.release_state = 1