etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改超时时间

master
Cui YongXing 2024-09-09 19:14:12 +08:00
parent 62f7786ace
commit 804f90107c
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -8,19 +8,15 @@ import com.muyu.client.mysql.MySqlDataSource;
import com.muyu.client.mysql.MySqlQuery; import com.muyu.client.mysql.MySqlQuery;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.data.base.BaseQuery;
import com.muyu.common.domian.*; import com.muyu.common.domian.*;
import com.muyu.common.domian.basic.abstracts.DataTaskAbstracts; import com.muyu.common.domian.basic.abstracts.DataTaskAbstracts;
import com.muyu.common.domian.enums.Weight; import com.muyu.common.domian.enums.Weight;
import com.muyu.common.domian.req.TaskInfoListReq; import com.muyu.common.domian.req.TaskInfoListReq;
import com.muyu.common.domian.resp.TaskInfoResp; import com.muyu.common.domian.resp.TaskInfoResp;
import com.muyu.common.pool.MysqlPool;
import com.muyu.etl.domain.DataValue; import com.muyu.etl.domain.DataValue;
import com.muyu.remote.feign.DatasourceFeign; import com.muyu.remote.feign.DatasourceFeign;
import com.muyu.remote.feign.RuleFeign; import com.muyu.remote.feign.RuleFeign;
import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.common.domain.RuleEngineVersion;
import com.muyu.rule.common.utils.LoadEngineClass;
import com.muyu.task.server.mapper.TaskInfoMapper; import com.muyu.task.server.mapper.TaskInfoMapper;
import com.muyu.task.server.service.*; import com.muyu.task.server.service.*;
import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool; import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool;
@ -376,8 +372,6 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
* 存放实例化引擎的容器 * 存放实例化引擎的容器
*/ */
// @Autowired
// private LoadEngineClass loadEngineClass;
private void executeTheRule(DataValue[][] dataValues, HashMap<String, String> map, Long newBasicId, private void executeTheRule(DataValue[][] dataValues, HashMap<String, String> map, Long newBasicId,
Long tableId, Long taskId) { Long tableId, Long taskId) {