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);