调度强化

pull/22/MERGE
xueli.xue 4 years ago
parent 2ff11b5d3b
commit 57702ec2ab

@ -2064,16 +2064,16 @@ data: post-data
- 18、执行器Commandhandler示例任务优化修复极端情况下脚本进程挂起问题
- 19、[ING]任务触发参数优化:支持选择 "Cron触发"、"固定间隔时间触发"、"指定时间点触发"、"不选择" 等;
- 20、[ING]任务 misfire 策略忽略、补偿一次、补偿最近10次……等
- 21、[规划中]分片任务:全部完成后才会出发后置节点;
- 22、[规划中]执行器注册,异步写入;
- 21、[规划中]执行器注册,异步写入;
### 7.32 版本 v2.3.0 Release Notes[规划中]
- 1、[规划中]DAG流程任务
- 1、[规划中]分片任务:全部完成后才会出发后置节点;
- 2、[规划中]DAG流程任务
- DAG任务支持参数传递共享数据DAG任务创建、管理DAG任务日志查看、操作
- 子任务:废弃
- 2、[规划中]多数据库支持DAO层通过JPA实现不限制数据库类型
- 3、[规划中]告警增强:邮件告警 + webhook告警
- 3、[规划中]多数据库支持DAO层通过JPA实现不限制数据库类型
- 4、[规划中]告警增强:邮件告警 + webhook告警
### TODO LIST
- 1、任务分片路由分片采用一致性Hash算法计算出尽量稳定的分片顺序即使注册机器存在波动也不会引起分批分片顺序大的波动目前采用IP自然排序可以满足需求待定

@ -18,7 +18,7 @@ CREATE TABLE `xxl_job_info` (
`alarm_email` varchar(255) DEFAULT NULL COMMENT '报警邮件',
`schedule_type` varchar(50) NOT NULL DEFAULT 'NONE' COMMENT '调度类型',
`schedule_conf` varchar(128) DEFAULT NULL COMMENT '调度配置,值含义取决于调度类型',
`misfire_strategy` varchar(50) NOT NULL DEFAULT 'DO_NOTHING' COMMENT '过期任务处理机制',
`misfire_strategy` varchar(50) NOT NULL DEFAULT 'DO_NOTHING' COMMENT '调度过期策略',
`executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',
`executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
`executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',

@ -6,6 +6,8 @@ import com.xxl.job.admin.core.model.XxlJobGroup;
import com.xxl.job.admin.core.model.XxlJobInfo;
import com.xxl.job.admin.core.model.XxlJobUser;
import com.xxl.job.admin.core.route.ExecutorRouteStrategyEnum;
import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum;
import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum;
import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
import com.xxl.job.admin.core.trigger.TriggerTypeEnum;
import com.xxl.job.admin.core.util.I18nUtil;
@ -47,6 +49,8 @@ public class JobInfoController {
model.addAttribute("ExecutorRouteStrategyEnum", ExecutorRouteStrategyEnum.values()); // 路由策略-列表
model.addAttribute("GlueTypeEnum", GlueTypeEnum.values()); // Glue类型-字典
model.addAttribute("ExecutorBlockStrategyEnum", ExecutorBlockStrategyEnum.values()); // 阻塞处理策略-字典
model.addAttribute("ScheduleTypeEnum", ScheduleTypeEnum.values()); // 调度类型
model.addAttribute("MisfireStrategyEnum", MisfireStrategyEnum.values()); // 调度过期策略
// 执行器列表
List<XxlJobGroup> jobGroupList_all = xxlJobGroupDao.findAll();

Loading…
Cancel
Save