diff --git a/cloud-task-common/pom.xml b/cloud-task-common/pom.xml index c243eca..7f73f9d 100644 --- a/cloud-task-common/pom.xml +++ b/cloud-task-common/pom.xml @@ -29,6 +29,7 @@ cloud-etl-common 1.0.0 + diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index bcf5575..631d0af 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -7,7 +7,10 @@ import com.muyu.common.core.utils.StringUtils; import com.muyu.domain.*; import com.muyu.domain.req.TaskInfoReq; import com.muyu.mapper.TaskMapper; -import com.muyu.service.*; +import com.muyu.service.TaskInputService; +import com.muyu.service.TaskJoinService; +import com.muyu.service.TaskOutputService; +import com.muyu.service.TaskService; import com.muyu.task.feign.DataValueClient; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; @@ -16,7 +19,6 @@ import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.HashSet; import java.util.List; -import java.util.concurrent.ConcurrentHashMap; import static com.muyu.task.PriorityThreadPool.*; @@ -346,8 +348,8 @@ public class TaskServiceImpl extends ServiceImpl implement // } } - @Autowired - private NodeRuleService nodeRuleService; +// @Autowired +// private NodeRuleService nodeRuleService; // @Autowired // private RuleFeign ruleFeign;