Apache-DolphinScheduler-1.2.1 源码: task 任务存储结构说明

小咪咪 2023-07-12 14:49 34阅读 0赞

**Table of Contents**

任务总体存储

Shell节点

SQL节点

存储过程节点

SPARK节点

MapReduce(MR)节点

Python节点

Flink节点

HTTP节点

子流程节点

依赖(DEPENDENT)节点

--------------------

## 任务总体存储 ##

在调度平台所创建的所有任务都保存在t\_ds\_process\_definition 表中.

该数据库表结构如下表所示:

<table> 
 <tbody> 
 <tr> 
 <td style="width:61.45pt;"> 序号 </td> 
 <td style="width:148.8pt;"> 字段 </td> 
 <td style="width:11.8pt;"> 类型 </td> 
 <td style="width:375.95pt;"> 注释 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 1 </td> 
 <td style="width:148.8pt;"> id </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 主键 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 2 </td> 
 <td style="width:148.8pt;"> name </td> 
 <td style="width:11.8pt;"> varchar </td> 
 <td style="width:375.95pt;"> 流程定义名称 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 3 </td> 
 <td style="width:148.8pt;"> version </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 流程定义版本 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 4 </td> 
 <td style="width:148.8pt;"> release_state </td> 
 <td style="width:11.8pt;"> tinyint </td> 
 <td style="width:375.95pt;"> 流程定义的发布状态：0 未上线 &nbsp;1已上线 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 5 </td> 
 <td style="width:148.8pt;"> project_id </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 项目id </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 6 </td> 
 <td style="width:148.8pt;"> user_id </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 流程定义所属用户id </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 7 </td> 
 <td style="width:148.8pt;"> process_definition_json </td> 
 <td style="width:11.8pt;"> longtext </td> 
 <td style="width:375.95pt;"> 流程定义json串 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 8 </td> 
 <td style="width:148.8pt;"> description </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 流程定义描述 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 9 </td> 
 <td style="width:148.8pt;"> global_params </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 全局参数 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 10 </td> 
 <td style="width:148.8pt;"> flag </td> 
 <td style="width:11.8pt;"> tinyint </td> 
 <td style="width:375.95pt;"> 流程是否可用：0 不可用，1 可用 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 11 </td> 
 <td style="width:148.8pt;"> locations </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 节点坐标信息 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 12 </td> 
 <td style="width:148.8pt;"> connects </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 节点连线信息 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 13 </td> 
 <td style="width:148.8pt;"> receivers </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 收件人 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 14 </td> 
 <td style="width:148.8pt;"> receivers_cc </td> 
 <td style="width:11.8pt;"> text </td> 
 <td style="width:375.95pt;"> 抄送人 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 15 </td> 
 <td style="width:148.8pt;"> create_time </td> 
 <td style="width:11.8pt;"> datetime </td> 
 <td style="width:375.95pt;"> 创建时间 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 16 </td> 
 <td style="width:148.8pt;"> timeout </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 超时时间 </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 17 </td> 
 <td style="width:148.8pt;"> tenant_id </td> 
 <td style="width:11.8pt;"> int </td> 
 <td style="width:375.95pt;"> 租户id </td> 
 </tr> 
 <tr> 
 <td style="width:61.45pt;"> 18 </td> 
 <td style="width:148.8pt;"> update_time </td> 
 <td style="width:11.8pt;"> datetime </td> 
 <td style="width:375.95pt;"> 更新时间 </td> 
 </tr> 
 </tbody> 
</table>

其中process\_definition\_json 字段为核心字段, 定义了 DAG 图中的任务信息.该数据以JSON 的方式进行存储.

公共的数据结构如下表.

数据示例

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "globalParams":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "prop":"golbal_bizdate", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "direct":"IN", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"VARCHAR", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":"${system.biz.date}" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp; "tasks":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object{...} &nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp; "tenantId":-1, &nbsp;&nbsp;&nbsp; "timeout":0 } </td> 
 </tr> 
 </tbody> 
</table>

## Shell节点 ##

Shell节点，在worker执行的时候，会生成一个临时Shell脚本，使用租户同名的linux用户执行这个脚本.

节点定义结构如下:

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> &nbsp;{ &nbsp;&nbsp;&nbsp; "type":"SHELL", &nbsp;&nbsp;&nbsp; "id":"tasks-17761", &nbsp;&nbsp;&nbsp; "name":"shell-task", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "resourceList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"spark-examples_2.11-2.4.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"hadoop-mapreduce-examples-2.7.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"prop":"local_param", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "direct":"IN", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"VARCHAR", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":"global_bizdate" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "rawScript":"echo "this is a shell task : ${local_param}"" &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp;&nbsp;&nbsp; ] } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## SQL节点 ##

通过 SQL对指定的数据源进行数据查询、更新操作.

节点定义结构如下。

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 序号 </td> 
 <td colspan="2" style="vertical-align:top;width:248.6pt;"> 参数名 </td> 
 <td style="vertical-align:top;width:141.2pt;"> 描述 </td> 
 <td style="vertical-align:top;width:84.15pt;"> 备注 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 1 </td> 
 <td style="vertical-align:top;width:130.8pt;"> type </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 类型 </td> 
 <td style="vertical-align:top;width:84.15pt;"> 值: SQL </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 2 </td> 
 <td style="vertical-align:top;width:130.8pt;"> id </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 任务编码 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 3 </td> 
 <td style="vertical-align:top;width:130.8pt;"> name </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 名称 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 4 </td> 
 <td style="vertical-align:top;width:130.8pt;"> params </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 自定义参数 </td> 
 <td style="vertical-align:top;width:84.15pt;"> Json 格式 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 5 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> type </td> 
 <td style="vertical-align:top;width:141.2pt;"> 数据库类型 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 6 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> datasource </td> 
 <td style="vertical-align:top;width:141.2pt;"> 数据源 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 7 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> sql </td> 
 <td style="vertical-align:top;width:141.2pt;"> Sql脚本 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 8 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> udfs </td> 
 <td style="vertical-align:top;width:141.2pt;"> Udf 函数 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 9 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> sqlType </td> 
 <td style="vertical-align:top;width:141.2pt;"> SQL 类型 </td> 
 <td style="vertical-align:top;width:84.15pt;"> 0 查询 &nbsp; 1 非查询 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 10 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> title </td> 
 <td style="vertical-align:top;width:141.2pt;"> 邮件标题 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 11 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> receivers </td> 
 <td style="vertical-align:top;width:141.2pt;"> 邮件接收人 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 12 </td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> receiversCc </td> 
 <td style="vertical-align:top;width:141.2pt;"> 邮件抄送人 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">13</td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> showType </td> 
 <td style="vertical-align:top;width:141.2pt;"> 接收类型 </td> 
 <td style="vertical-align:top;width:84.15pt;"> TABLE 表格 ATTACHMENT附件 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">14</td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> localParams </td> 
 <td style="vertical-align:top;width:141.2pt;"> 本地变量 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">15</td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> connParams </td> 
 <td style="vertical-align:top;width:141.2pt;"> 连接参数 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">16</td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> preStatements </td> 
 <td style="vertical-align:top;width:141.2pt;"> 前置 SQL </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">17</td> 
 <td style="vertical-align:top;width:130.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:117.8pt;"> postStatements </td> 
 <td style="vertical-align:top;width:141.2pt;"> 后置 SQL </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">18</td> 
 <td style="vertical-align:top;width:130.8pt;"> description </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 描述 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">19</td> 
 <td style="vertical-align:top;width:130.8pt;"> runFlag </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 运行标识 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">20</td> 
 <td style="vertical-align:top;width:130.8pt;"> dependence </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 任务依赖 </td> 
 <td style="vertical-align:top;width:84.15pt;"> 与params互斥 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">21</td> 
 <td style="vertical-align:top;width:130.8pt;"> maxRetryTimes </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 最大重试次数 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">22</td> 
 <td style="vertical-align:top;width:130.8pt;"> retryInterval </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 重试间隔 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">23</td> 
 <td style="vertical-align:top;width:130.8pt;"> timeout </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 超时控制 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">24</td> 
 <td style="vertical-align:top;width:130.8pt;"> taskInstancePriority </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 任务优先级 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">25</td> 
 <td style="vertical-align:top;width:130.8pt;"> workerGroupId </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> Worker 分组 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">26</td> 
 <td style="vertical-align:top;width:130.8pt;"> preTasks </td> 
 <td style="vertical-align:top;width:117.8pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:141.2pt;"> 前置任务 </td> 
 <td style="vertical-align:top;width:84.15pt;"> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"SQL", &nbsp;&nbsp;&nbsp; "id":"tasks-17811", &nbsp;&nbsp;&nbsp; "name":"SQL节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"MYSQL", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "datasource":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "sql":"show databases;", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "udfs":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "sqlType":"0", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "title":"SQL节点", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "receivers":"zhangboyi_mx@163.com", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "receiversCc":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "showType":"TABLE,ATTACHMENT", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "connParams":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "preStatements":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "select user();" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "postStatements":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "select database();" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ] &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## 存储过程节点 ##

根据选择的数据源，执行存储过程.

节点定义结构如下:

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> "type":"PROCEDURE", &nbsp;&nbsp;&nbsp; "id":"tasks-33589", &nbsp;&nbsp;&nbsp; "name":"存储过程节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"MYSQL", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "datasource":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "method":"add", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "prop":"in_paramer", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "direct":"IN", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"VARCHAR", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":"" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "prop":"out_paramer", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "direct":"OUT", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "type":"VARCHAR", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":"" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ] &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## SPARK节点 ##

通过SPARK节点，可以直接直接执行SPARK程序，对于spark节点，worker会使用spark-submit方式提交任务.

节点定义结构如下:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 序号 </td> 
 <td colspan="2" style="vertical-align:top;width:279.45pt;"> 参数名 </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 备注 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 1 </td> 
 <td style="vertical-align:top;width:153.85pt;"> type </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 值: SPARK </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 2 </td> 
 <td style="vertical-align:top;width:153.85pt;"> id </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务编码 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 3 </td> 
 <td style="vertical-align:top;width:153.85pt;"> name </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 名称 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 4 </td> 
 <td style="vertical-align:top;width:153.85pt;"> params </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 自定义参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> Json 格式 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 5 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainClass </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行主类 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 6 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainJar </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序 jar 包 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 7 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> deployMode </td> 
 <td style="vertical-align:top;width:116.7pt;"> 部署模式 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 8 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> resourceList </td> 
 <td style="vertical-align:top;width:116.7pt;"> 引用资源文件 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 9 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> localParams </td> 
 <td style="vertical-align:top;width:116.7pt;"> 本地变量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 10 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> driverCores </td> 
 <td style="vertical-align:top;width:116.7pt;"> driver核数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 11 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> driverMemory </td> 
 <td style="vertical-align:top;width:116.7pt;"> driver 内存数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 12 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> numExecutors </td> 
 <td style="vertical-align:top;width:116.7pt;"> executor数量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 13 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> executorMemory </td> 
 <td style="vertical-align:top;width:116.7pt;"> executor内存 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 14 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> executorCores </td> 
 <td style="vertical-align:top;width:116.7pt;"> executor核数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 15 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainArgs </td> 
 <td style="vertical-align:top;width:116.7pt;"> 主参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 16 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> others </td> 
 <td style="vertical-align:top;width:116.7pt;"> 其他参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">17</td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> programType </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">18</td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> sparkVersion </td> 
 <td style="vertical-align:top;width:116.7pt;"> Spark 版本 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">19</td> 
 <td style="vertical-align:top;width:153.85pt;"> description </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">20</td> 
 <td style="vertical-align:top;width:153.85pt;"> runFlag </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行标识 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">21</td> 
 <td style="vertical-align:top;width:153.85pt;"> dependence </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务依赖 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 与params互斥 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">22</td> 
 <td style="vertical-align:top;width:153.85pt;"> maxRetryTimes </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 最大重试次数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">23</td> 
 <td style="vertical-align:top;width:153.85pt;"> retryInterval </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 重试间隔 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">24</td> 
 <td style="vertical-align:top;width:153.85pt;"> timeout </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 超时控制 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">25</td> 
 <td style="vertical-align:top;width:153.85pt;"> taskInstancePriority </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务优先级 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">26</td> 
 <td style="vertical-align:top;width:153.85pt;"> workerGroupId </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> Worker 分组 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">27</td> 
 <td style="vertical-align:top;width:153.85pt;"> preTasks </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 前置任务 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"SPARK", &nbsp;&nbsp;&nbsp; "id":"tasks-46459", &nbsp;&nbsp;&nbsp; "name":"SPARK节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainClass":"org.apache.spark.examples.SparkPi", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainJar":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"spark-examples_2.11-2.4.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "deployMode":"cluster", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "resourceList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"spark-examples_2.11-2.4.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "driverCores":1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "driverMemory":"512M", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "numExecutors":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "executorMemory":"2G", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "executorCores":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainArgs":"10", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "others":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "programType":"SCALA", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "sparkVersion":"SPARK2" &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## MapReduce(MR)节点 ##

使用MR节点，可以直接执行MR程序。对于mr节点，worker会使用hadoop jar方式提交任务.

节点定义结构如下:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 序号 </td> 
 <td colspan="2" style="vertical-align:top;width:279.45pt;"> 参数名 </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 备注 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 1 </td> 
 <td style="vertical-align:top;width:153.85pt;"> type </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 值: MR </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 2 </td> 
 <td style="vertical-align:top;width:153.85pt;"> id </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务编码 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 3 </td> 
 <td style="vertical-align:top;width:153.85pt;"> name </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 名称 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 4 </td> 
 <td style="vertical-align:top;width:153.85pt;"> params </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 自定义参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> Json 格式 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 5 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainClass </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行主类 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 6 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainJar </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序 jar 包 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 7 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> resourceList </td> 
 <td style="vertical-align:top;width:116.7pt;"> 引用资源文件 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 8 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainArgs </td> 
 <td style="vertical-align:top;width:116.7pt;"> 主参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 9 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> others </td> 
 <td style="vertical-align:top;width:116.7pt;"> 其他参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 10 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> programType </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 11 </td> 
 <td style="vertical-align:top;width:153.85pt;"> description </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 12 </td> 
 <td style="vertical-align:top;width:153.85pt;"> runFlag </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行标识 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 13 </td> 
 <td style="vertical-align:top;width:153.85pt;"> dependence </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务依赖 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 与params互斥 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 14 </td> 
 <td style="vertical-align:top;width:153.85pt;"> maxRetryTimes </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 最大重试次数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 15 </td> 
 <td style="vertical-align:top;width:153.85pt;"> retryInterval </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 重试间隔 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 16 </td> 
 <td style="vertical-align:top;width:153.85pt;"> timeout </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 超时控制 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">17</td> 
 <td style="vertical-align:top;width:153.85pt;"> taskInstancePriority </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务优先级 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">18</td> 
 <td style="vertical-align:top;width:153.85pt;"> workerGroupId </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> Worker 分组 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">19</td> 
 <td style="vertical-align:top;width:153.85pt;"> preTasks </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 前置任务 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"MR", &nbsp;&nbsp;&nbsp; "id":"tasks-70322", &nbsp;&nbsp;&nbsp; "name":"MapReduce(MR)节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainClass":"wordcount", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainJar":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"hadoop-mapreduce-examples-2.7.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "resourceList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"res":"hadoop-mapreduce-examples-2.7.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainArgs":"/wordcount/input /wordcount/output/result", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "others":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "programType":"JAVA" &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp; &nbsp;"runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## Python节点 ##

使用Python节点，可以直接执行python脚本，对于python节点，worker会使用python \*\*方式提交任务.

节点定义结构如下:

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"PYTHON", &nbsp;&nbsp;&nbsp; "id":"tasks-23887", &nbsp;&nbsp;&nbsp; "name":" Python节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "resourceList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"hadoop-mapreduce-examples-2.7.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"spark-examples_2.11-2.4.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "rawScript":"print("this is python task ..")" &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## Flink节点 ##

根据配置调用 Flink 请求.

节点定义结构如下:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 序号 </td> 
 <td colspan="2" style="vertical-align:top;width:279.45pt;"> 参数名 </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 备注 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 1 </td> 
 <td style="vertical-align:top;width:153.85pt;"> type </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 值: FLINK </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 2 </td> 
 <td style="vertical-align:top;width:153.85pt;"> id </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务编码 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 3 </td> 
 <td style="vertical-align:top;width:153.85pt;"> name </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 名称 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 4 </td> 
 <td style="vertical-align:top;width:153.85pt;"> params </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 自定义参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> Json 格式 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 5 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainClass </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行主类 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 6 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainJar </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序 jar 包 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 7 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> deployMode </td> 
 <td style="vertical-align:top;width:116.7pt;"> 部署模式 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 8 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> resourceList </td> 
 <td style="vertical-align:top;width:116.7pt;"> 引用资源文件 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 9 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> localParams </td> 
 <td style="vertical-align:top;width:116.7pt;"> 本地变量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 10 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> slot </td> 
 <td style="vertical-align:top;width:116.7pt;"> Slot数量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 11 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> taskManager </td> 
 <td style="vertical-align:top;width:116.7pt;"> taskManager数量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 12 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> taskManagerMemory </td> 
 <td style="vertical-align:top;width:116.7pt;"> taskManager内存 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 13 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> jobManagerMemory </td> 
 <td style="vertical-align:top;width:116.7pt;"> jobManager内存 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 14 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> executorCores </td> 
 <td style="vertical-align:top;width:116.7pt;"> executor核数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 15 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> mainArgs </td> 
 <td style="vertical-align:top;width:116.7pt;"> 主参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 16 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> others </td> 
 <td style="vertical-align:top;width:116.7pt;"> 其他参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">17</td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> programType </td> 
 <td style="vertical-align:top;width:116.7pt;"> 程序类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">18</td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> sparkVersion </td> 
 <td style="vertical-align:top;width:116.7pt;"> Spark 版本 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">19</td> 
 <td style="vertical-align:top;width:153.85pt;"> description </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">20</td> 
 <td style="vertical-align:top;width:153.85pt;"> runFlag </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行标识 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">21</td> 
 <td style="vertical-align:top;width:153.85pt;"> dependence </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务依赖 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 与params互斥 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">22</td> 
 <td style="vertical-align:top;width:153.85pt;"> maxRetryTimes </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 最大重试次数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">23</td> 
 <td style="vertical-align:top;width:153.85pt;"> retryInterval </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 重试间隔 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">24</td> 
 <td style="vertical-align:top;width:153.85pt;"> timeout </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 超时控制 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">25</td> 
 <td style="vertical-align:top;width:153.85pt;"> taskInstancePriority </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务优先级 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">26</td> 
 <td style="vertical-align:top;width:153.85pt;"> workerGroupId </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> Worker 分组 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">27</td> 
 <td style="vertical-align:top;width:153.85pt;"> preTasks </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 前置任务 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"FLINK", &nbsp;&nbsp;&nbsp; "id":"tasks-84250", &nbsp;&nbsp;&nbsp; "name":"Flink节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainClass":"org.apache.spark.examples.SparkPi", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainJar":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "res":"spark-examples_2.11-2.4.4.jar" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "deployMode":"cluster", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "resourceList":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "slot":1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "taskManager":"2", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "jobManagerMemory":"1G", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "taskManagerMemory":"2G", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "executorCores":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "mainArgs":"10", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "others":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "programType":"SCALA" &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## HTTP节点 ##

根据配置调用 HTTP 请求.

节点定义结构如下:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 序号 </td> 
 <td colspan="2" style="vertical-align:top;width:279.45pt;"> 参数名 </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 备注 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 1 </td> 
 <td style="vertical-align:top;width:153.85pt;"> type </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 类型 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 值: HTTP </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 2 </td> 
 <td style="vertical-align:top;width:153.85pt;"> id </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务编码 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 3 </td> 
 <td style="vertical-align:top;width:153.85pt;"> name </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 名称 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 4 </td> 
 <td style="vertical-align:top;width:153.85pt;"> params </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 自定义参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> Json 格式 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 5 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> localParams </td> 
 <td style="vertical-align:top;width:116.7pt;"> 本地变量 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 6 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> httpParams </td> 
 <td style="vertical-align:top;width:116.7pt;"> 请求参数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 7 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> url </td> 
 <td style="vertical-align:top;width:116.7pt;"> url 地址 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 8 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> httpMethod </td> 
 <td style="vertical-align:top;width:116.7pt;"> 请求方式 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 9 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> httpCheckCondition </td> 
 <td style="vertical-align:top;width:116.7pt;"> 检查条件 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 10 </td> 
 <td style="vertical-align:top;width:153.85pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:125.6pt;"> condition </td> 
 <td style="vertical-align:top;width:116.7pt;"> 检查内容 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 11 </td> 
 <td style="vertical-align:top;width:153.85pt;"> description </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 描述 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 12 </td> 
 <td style="vertical-align:top;width:153.85pt;"> runFlag </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 运行标识 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 13 </td> 
 <td style="vertical-align:top;width:153.85pt;"> dependence </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务依赖 </td> 
 <td style="vertical-align:top;width:82.3pt;"> 与params互斥 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 14 </td> 
 <td style="vertical-align:top;width:153.85pt;"> maxRetryTimes </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 最大重试次数 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 15 </td> 
 <td style="vertical-align:top;width:153.85pt;"> retryInterval </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 重试间隔 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:44.35pt;"> 16 </td> 
 <td style="vertical-align:top;width:153.85pt;"> timeout </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 超时控制 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">17</td> 
 <td style="vertical-align:top;width:153.85pt;"> taskInstancePriority </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 任务优先级 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">18</td> 
 <td style="vertical-align:top;width:153.85pt;"> workerGroupId </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> Worker 分组 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:48.85pt;">19</td> 
 <td style="vertical-align:top;width:153.85pt;"> preTasks </td> 
 <td style="vertical-align:top;width:125.6pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:116.7pt;"> 前置任务 </td> 
 <td style="vertical-align:top;width:82.3pt;"> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"HTTP", &nbsp;&nbsp;&nbsp; "id":"tasks-31113", &nbsp;&nbsp;&nbsp; "name":"http节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "localParams":[ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "httpParams":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "prop":"id", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "httpParametersType":"PARAMETER", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":"GRESFWW" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "url":"http://www.ysstech.com/", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "httpMethod":"GET", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "httpCheckCondition":"STATUS_CODE_DEFAULT", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "condition":"" &nbsp;&nbsp; &nbsp;}, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## 子流程节点 ##

子流程节点，就是把外部的某个工作流定义当做一个任务节点去执行.

节点定义结构如下:

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"SUB_PROCESS", &nbsp;&nbsp;&nbsp; "id":"tasks-22568", &nbsp;&nbsp;&nbsp; "name":"子流程节点-task", &nbsp;&nbsp;&nbsp; "params":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "processDefinitionId":2 &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>

## 依赖(DEPENDENT)节点 ##

依赖节点，就是依赖检查节点。比如A流程依赖昨天的B流程执行成功，依赖节点会去检查B流程在昨天是否有执行成功的实例.

节点定义结构如下:

数据示例:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:522.8pt;"> { &nbsp;&nbsp;&nbsp; "type":"DEPENDENT", &nbsp;&nbsp;&nbsp; "id":"tasks-3383", &nbsp;&nbsp;&nbsp; "name":" 依赖(DEPENDENT)节点", &nbsp;&nbsp;&nbsp; "params":{ &nbsp; &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "description":"", &nbsp;&nbsp;&nbsp; "runFlag":"NORMAL", &nbsp;&nbsp;&nbsp; "dependence":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "relation":"AND", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "dependTaskList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "relation":"AND", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "dependItemList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "projectId":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "definitionId":3, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "definitionList":[ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":3, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "label":"子流程节点" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "value":2, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "label":"shell-task" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ], &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "depTasks":"ALL", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "cycle":"day", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "dateValue":"today" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ] &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "maxRetryTimes":"0", &nbsp;&nbsp;&nbsp; "retryInterval":"1", &nbsp;&nbsp;&nbsp; "timeout":{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "strategy":"", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "interval":null, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "enable":false &nbsp;&nbsp;&nbsp; }, &nbsp;&nbsp;&nbsp; "taskInstancePriority":"MEDIUM", &nbsp;&nbsp;&nbsp; "workerGroupId":-1, &nbsp;&nbsp;&nbsp; "preTasks":[ &nbsp; &nbsp;&nbsp;&nbsp; ] } </td> 
 </tr> 
 </tbody> 
</table>