| 12345678910111213141516171819202122232425262728293031323334 |
- create table sj_job_task
- (
- id bigint unsigned auto_increment comment '主键'
- primary key,
- namespace_id varchar(64) default '764d604ec6fc45f68cd92514c40e9e1a' not null comment '命名空间id',
- group_name varchar(64) not null comment '组名称',
- job_id bigint not null comment '任务信息id',
- task_batch_id bigint not null comment '调度任务id',
- parent_id bigint default 0 not null comment '父执行器id',
- task_status tinyint default 0 not null comment '执行的状态 0、失败 1、成功',
- retry_count int default 0 not null comment '重试次数',
- mr_stage tinyint null comment '动态分片所处阶段 1:map 2:reduce 3:mergeReduce',
- leaf tinyint default 1 not null comment '叶子节点',
- task_name varchar(255) default '' not null comment '任务名称',
- client_info varchar(128) null comment '客户端地址 clientId#ip:port',
- wf_context text null comment '工作流全局上下文',
- result_message text not null comment '执行结果',
- args_str text null comment '执行方法参数',
- args_type tinyint default 1 not null comment '参数类型 ',
- ext_attrs varchar(256) default '' null comment '扩展字段',
- create_dt datetime default CURRENT_TIMESTAMP not null comment '创建时间',
- update_dt datetime default CURRENT_TIMESTAMP not null on update CURRENT_TIMESTAMP comment '修改时间'
- )
- comment '任务实例';
- create index idx_create_dt
- on sj_job_task (create_dt);
- create index idx_namespace_id_group_name
- on sj_job_task (namespace_id, group_name);
- create index idx_task_batch_id_task_status
- on sj_job_task (task_batch_id, task_status);
|
