You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
40 KiB
40 KiB
Task Structure
Overall Tasks Storage Structure
All tasks in DolphinScheduler are saved in the t_ds_process_definition table.
The following shows the t_ds_process_definition table structure:
| No. | field | type | description |
|---|---|---|---|
| 1 | id | int(11) | primary key |
| 2 | name | varchar(255) | process definition name |
| 3 | version | int(11) | process definition version |
| 4 | release_state | tinyint(4) | release status of process definition: 0 not released, 1 released |
| 5 | project_id | int(11) | project id |
| 6 | user_id | int(11) | user id of the process definition |
| 7 | process_definition_json | longtext | process definition JSON |
| 8 | description | text | process definition description |
| 9 | global_params | text | global parameters |
| 10 | flag | tinyint(4) | specify whether the process is available: 0 is not available, 1 is available |
| 11 | locations | text | node location information |
| 12 | connects | text | node connectivity info |
| 13 | receivers | text | receivers |
| 14 | receivers_cc | text | CC receivers |
| 15 | create_time | datetime | create time |
| 16 | timeout | int(11) | timeout |
| 17 | tenant_id | int(11) | tenant id |
| 18 | update_time | datetime | update time |
| 19 | modify_by | varchar(36) | specify the user that made the modification |
| 20 | resource_ids | varchar(255) | resource ids |
The process_definition_json field is the core field, which defines the task information in the DAG diagram, and it is stored in JSON format.
The following table describes the common data structure.
| No. | field | type | description |
|---|---|---|---|
| 1 | globalParams | Array | global parameters |
| 2 | tasks | Array | task collections in the process [for the structure of each type, please refer to the following sections] |
| 3 | tenantId | int | tenant ID |
| 4 | timeout | int | timeout |
Data example:
{
"globalParams":[
{
"prop":"golbal_bizdate",
"direct":"IN",
"type":"VARCHAR",
"value":"${system.biz.date}"
}
],
"tasks":Array[1],
"tenantId":0,
"timeout":0
}
The Detailed Explanation of The Storage Structure of Each Task Type
Shell Nodes
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | SHELL | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | rawScript | String | Shell script | ||
| 6 | localParams | Array | customized local parameters | ||
| 7 | resourceList | Array | resource files | ||
| 8 | description | String | description | ||
| 9 | runFlag | String | execution flag | ||
| 10 | conditionResult | Object | condition branch | ||
| 11 | successNode | Array | jump to node if success | ||
| 12 | failedNode | Array | jump to node if failure | ||
| 13 | dependence | Object | task dependency | mutual exclusion with params | |
| 14 | maxRetryTimes | String | max retry times | ||
| 15 | retryInterval | String | retry interval | ||
| 16 | timeout | Object | timeout | ||
| 17 | taskInstancePriority | String | task priority | ||
| 18 | workerGroup | String | Worker group | ||
| 19 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"SHELL",
"id":"tasks-80760",
"name":"Shell Task",
"params":{
"resourceList":[
{
"id":3,
"name":"run.sh",
"res":"run.sh"
}
],
"localParams":[
],
"rawScript":"echo "This is a shell script""
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
SQL Node
Perform data query and update operations on the specified datasource through SQL.
The following shows the node data structure:
| No. | parameter name | type | description | note | |
|---|---|---|---|---|---|
| 1 | id | String | task id | ||
| 2 | type | String | task type | SQL | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | type | String | database type | ||
| 6 | datasource | Int | datasource id | ||
| 7 | sql | String | query SQL statement | ||
| 8 | udfs | String | udf functions | specify UDF function ids, separate by comma | |
| 9 | sqlType | String | SQL node type | 0 for query and 1 for none-query SQL | |
| 10 | title | String | mail title | ||
| 11 | receivers | String | receivers | ||
| 12 | receiversCc | String | CC receivers | ||
| 13 | showType | String | display type of mail | options: TABLE or ATTACHMENT | |
| 14 | connParams | String | connect parameters | ||
| 15 | preStatements | Array | preposition SQL statements | ||
| 16 | postStatements | Array | post-position SQL statements | ||
| 17 | localParams | Array | customized parameters | ||
| 18 | description | String | description | ||
| 19 | runFlag | String | execution flag | ||
| 20 | conditionResult | Object | condition branch | ||
| 21 | successNode | Array | jump to node if success | ||
| 22 | failedNode | Array | jump to node if failure | ||
| 23 | dependence | Object | task dependency | mutual exclusion with params | |
| 24 | maxRetryTimes | String | max retry times | ||
| 25 | retryInterval | String | retry interval | ||
| 26 | timeout | Object | timeout | ||
| 27 | taskInstancePriority | String | task priority | ||
| 28 | workerGroup | String | Worker group | ||
| 29 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"SQL",
"id":"tasks-95648",
"name":"SqlTask-Query",
"params":{
"type":"MYSQL",
"datasource":1,
"sql":"select id , namge , age from emp where id = ${id}",
"udfs":"",
"sqlType":"0",
"title":"xxxx@xxx.com",
"receivers":"xxxx@xxx.com",
"receiversCc":"",
"showType":"TABLE",
"localParams":[
{
"prop":"id",
"direct":"IN",
"type":"INTEGER",
"value":"1"
}
],
"connParams":"",
"preStatements":[
"insert into emp ( id,name ) value (1,'Li' )"
],
"postStatements":[
]
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
Procedure [stored procedures] Node
The following shows the node data structure: Node data example:
Spark Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | SPARK | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | mainClass | String | main class | ||
| 6 | mainArgs | String | execution arguments | ||
| 7 | others | String | other arguments | ||
| 8 | mainJar | Object | application jar package | ||
| 9 | deployMode | String | deployment mode | local,client,cluster | |
| 10 | driverCores | String | driver cores | ||
| 11 | driverMemory | String | driver memory | ||
| 12 | numExecutors | String | executor count | ||
| 13 | executorMemory | String | executor memory | ||
| 14 | executorCores | String | executor cores | ||
| 15 | programType | String | program type | JAVA,SCALA,PYTHON | |
| 16 | sparkVersion | String | Spark version | SPARK1 , SPARK2 | |
| 17 | localParams | Array | customized local parameters | ||
| 18 | resourceList | Array | resource files | ||
| 19 | description | String | description | ||
| 20 | runFlag | String | execution flag | ||
| 21 | conditionResult | Object | condition branch | ||
| 22 | successNode | Array | jump to node if success | ||
| 23 | failedNode | Array | jump to node if failure | ||
| 24 | dependence | Object | task dependency | mutual exclusion with params | |
| 25 | maxRetryTimes | String | max retry times | ||
| 26 | retryInterval | String | retry interval | ||
| 27 | timeout | Object | timeout | ||
| 28 | taskInstancePriority | String | task priority | ||
| 29 | workerGroup | String | Worker group | ||
| 30 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"SPARK",
"id":"tasks-87430",
"name":"SparkTask",
"params":{
"mainClass":"org.apache.spark.examples.SparkPi",
"mainJar":{
"id":4
},
"deployMode":"cluster",
"resourceList":[
{
"id":3,
"name":"run.sh",
"res":"run.sh"
}
],
"localParams":[
],
"driverCores":1,
"driverMemory":"512M",
"numExecutors":2,
"executorMemory":"2G",
"executorCores":2,
"mainArgs":"10",
"others":"",
"programType":"SCALA",
"sparkVersion":"SPARK2"
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
MapReduce(MR) Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | MR | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | mainClass | String | main class | ||
| 6 | mainArgs | String | execution arguments | ||
| 7 | others | String | other arguments | ||
| 8 | mainJar | Object | application jar package | ||
| 9 | programType | String | program type | JAVA,PYTHON | |
| 10 | localParams | Array | customized local parameters | ||
| 11 | resourceList | Array | resource files | ||
| 12 | description | String | description | ||
| 13 | runFlag | String | execution flag | ||
| 14 | conditionResult | Object | condition branch | ||
| 15 | successNode | Array | jump to node if success | ||
| 16 | failedNode | Array | jump to node if failure | ||
| 17 | dependence | Object | task dependency | mutual exclusion with params | |
| 18 | maxRetryTimes | String | max retry times | ||
| 19 | retryInterval | String | retry interval | ||
| 20 | timeout | Object | timeout | ||
| 21 | taskInstancePriority | String | task priority | ||
| 22 | workerGroup | String | Worker group | ||
| 23 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"MR",
"id":"tasks-28997",
"name":"MRTask",
"params":{
"mainClass":"wordcount",
"mainJar":{
"id":5
},
"resourceList":[
{
"id":3,
"name":"run.sh",
"res":"run.sh"
}
],
"localParams":[
],
"mainArgs":"/tmp/wordcount/input /tmp/wordcount/output/",
"others":"",
"programType":"JAVA"
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
Python Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | PYTHON | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | rawScript | String | Python script | ||
| 6 | localParams | Array | customized local parameters | ||
| 7 | resourceList | Array | resource files | ||
| 8 | description | String | description | ||
| 9 | runFlag | String | execution flag | ||
| 10 | conditionResult | Object | condition branch | ||
| 11 | successNode | Array | jump to node if success | ||
| 12 | failedNode | Array | jump to node if failure | ||
| 13 | dependence | Object | task dependency | mutual exclusion with params | |
| 14 | maxRetryTimes | String | max retry times | ||
| 15 | retryInterval | String | retry interval | ||
| 16 | timeout | Object | timeout | ||
| 17 | taskInstancePriority | String | task priority | ||
| 18 | workerGroup | String | Worker group | ||
| 19 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"PYTHON",
"id":"tasks-5463",
"name":"Python Task",
"params":{
"resourceList":[
{
"id":3,
"name":"run.sh",
"res":"run.sh"
}
],
"localParams":[
],
"rawScript":"print("This is a python script")"
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
Flink Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | FLINK | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | mainClass | String | main class | ||
| 6 | mainArgs | String | execution arguments | ||
| 7 | others | String | other arguments | ||
| 8 | mainJar | Object | application jar package | ||
| 9 | deployMode | String | deployment mode | local,client,cluster | |
| 10 | slot | String | slot count | ||
| 11 | taskManager | String | taskManager count | ||
| 12 | taskManagerMemory | String | taskManager memory size | ||
| 13 | jobManagerMemory | String | jobManager memory size | ||
| 14 | programType | String | program type | JAVA,SCALA,PYTHON | |
| 15 | localParams | Array | local parameters | ||
| 16 | resourceList | Array | resource files | ||
| 17 | description | String | description | ||
| 18 | runFlag | String | execution flag | ||
| 19 | conditionResult | Object | condition branch | ||
| 20 | successNode | Array | jump node if success | ||
| 21 | failedNode | Array | jump node if failure | ||
| 22 | dependence | Object | task dependency | mutual exclusion with params | |
| 23 | maxRetryTimes | String | max retry times | ||
| 24 | retryInterval | String | retry interval | ||
| 25 | timeout | Object | timeout | ||
| 26 | taskInstancePriority | String | task priority | ||
| 27 | workerGroup | String | Worker group | ||
| 38 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"FLINK",
"id":"tasks-17135",
"name":"FlinkTask",
"params":{
"mainClass":"com.flink.demo",
"mainJar":{
"id":6
},
"deployMode":"cluster",
"resourceList":[
{
"id":3,
"name":"run.sh",
"res":"run.sh"
}
],
"localParams":[
],
"slot":1,
"taskManager":"2",
"jobManagerMemory":"1G",
"taskManagerMemory":"2G",
"executorCores":2,
"mainArgs":"100",
"others":"",
"programType":"SCALA"
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
HTTP Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | HTTP | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | url | String | request url | ||
| 6 | httpMethod | String | http method | GET,POST,HEAD,PUT,DELETE | |
| 7 | httpParams | Array | http parameters | ||
| 8 | httpCheckCondition | String | validation of HTTP code status | default code 200 | |
| 9 | condition | String | validation conditions | ||
| 10 | localParams | Array | customized local parameters | ||
| 11 | description | String | description | ||
| 12 | runFlag | String | execution flag | ||
| 13 | conditionResult | Object | condition branch | ||
| 14 | successNode | Array | jump node if success | ||
| 15 | failedNode | Array | jump node if failure | ||
| 16 | dependence | Object | task dependency | mutual exclusion with params | |
| 17 | maxRetryTimes | String | max retry times | ||
| 18 | retryInterval | String | retry interval | ||
| 19 | timeout | Object | timeout | ||
| 20 | taskInstancePriority | String | task priority | ||
| 21 | workerGroup | String | Worker group | ||
| 22 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"HTTP",
"id":"tasks-60499",
"name":"HttpTask",
"params":{
"localParams":[
],
"httpParams":[
{
"prop":"id",
"httpParametersType":"PARAMETER",
"value":"1"
},
{
"prop":"name",
"httpParametersType":"PARAMETER",
"value":"Bo"
}
],
"url":"https://www.xxxxx.com:9012",
"httpMethod":"POST",
"httpCheckCondition":"STATUS_CODE_DEFAULT",
"condition":""
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
DataX Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task Id | ||
| 2 | type | String | task type | DATAX | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | customConfig | Int | specify whether use customized config | 0 none customized, 1 customized | |
| 6 | dsType | String | datasource type | ||
| 7 | dataSource | Int | datasource ID | ||
| 8 | dtType | String | target database type | ||
| 9 | dataTarget | Int | target database ID | ||
| 10 | sql | String | SQL statements | ||
| 11 | targetTable | String | target table | ||
| 12 | jobSpeedByte | Int | job speed limiting(bytes) | ||
| 13 | jobSpeedRecord | Int | job speed limiting(records) | ||
| 14 | preStatements | Array | preposition SQL | ||
| 15 | postStatements | Array | post-position SQL | ||
| 16 | json | String | customized configs | valid if customConfig=1 | |
| 17 | localParams | Array | customized parameters | valid if customConfig=1 | |
| 18 | description | String | description | ||
| 19 | runFlag | String | execution flag | ||
| 20 | conditionResult | Object | condition branch | ||
| 21 | successNode | Array | jump node if success | ||
| 22 | failedNode | Array | jump node if failure | ||
| 23 | dependence | Object | task dependency | mutual exclusion with params | |
| 24 | maxRetryTimes | String | max retry times | ||
| 25 | retryInterval | String | retry interval | ||
| 26 | timeout | Object | timeout | ||
| 27 | taskInstancePriority | String | task priority | ||
| 28 | workerGroup | String | Worker group | ||
| 29 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"DATAX",
"id":"tasks-91196",
"name":"DataxTask-DB",
"params":{
"customConfig":0,
"dsType":"MYSQL",
"dataSource":1,
"dtType":"MYSQL",
"dataTarget":1,
"sql":"select id, name ,age from user ",
"targetTable":"emp",
"jobSpeedByte":524288,
"jobSpeedRecord":500,
"preStatements":[
"truncate table emp "
],
"postStatements":[
"truncate table user"
]
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
Sqoop Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task ID | ||
| 2 | type | String | task type | SQOOP | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | concurrency | Int | concurrency rate | ||
| 6 | modelType | String | flow direction | import,export | |
| 7 | sourceType | String | datasource type | ||
| 8 | sourceParams | String | datasource parameters | JSON format | |
| 9 | targetType | String | target datasource type | ||
| 10 | targetParams | String | target datasource parameters | JSON format | |
| 11 | localParams | Array | customized local parameters | ||
| 12 | description | String | description | ||
| 13 | runFlag | String | execution flag | ||
| 14 | conditionResult | Object | condition branch | ||
| 15 | successNode | Array | jump node if success | ||
| 16 | failedNode | Array | jump node if failure | ||
| 17 | dependence | Object | task dependency | mutual exclusion with params | |
| 18 | maxRetryTimes | String | max retry times | ||
| 19 | retryInterval | String | retry interval | ||
| 20 | timeout | Object | timeout | ||
| 21 | taskInstancePriority | String | task priority | ||
| 22 | workerGroup | String | Worker group | ||
| 23 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"SQOOP",
"id":"tasks-82041",
"name":"Sqoop Task",
"params":{
"concurrency":1,
"modelType":"import",
"sourceType":"MYSQL",
"targetType":"HDFS",
"sourceParams":"{"srcType":"MYSQL","srcDatasource":1,"srcTable":"","srcQueryType":"1","srcQuerySql":"selec id , name from user","srcColumnType":"0","srcColumns":"","srcConditionList":[],"mapColumnHive":[{"prop":"hivetype-key","direct":"IN","type":"VARCHAR","value":"hivetype-value"}],"mapColumnJava":[{"prop":"javatype-key","direct":"IN","type":"VARCHAR","value":"javatype-value"}]}",
"targetParams":"{"targetPath":"/user/hive/warehouse/ods.db/user","deleteTargetDir":false,"fileType":"--as-avrodatafile","compressionCodec":"snappy","fieldsTerminated":",","linesTerminated":"@"}",
"localParams":[
]
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
Condition Branch Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task ID | ||
| 2 | type | String | task type | SHELL | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | null | |
| 5 | description | String | description | ||
| 6 | runFlag | String | execution flag | ||
| 7 | conditionResult | Object | condition branch | ||
| 8 | successNode | Array | jump to node if success | ||
| 9 | failedNode | Array | jump to node if failure | ||
| 10 | dependence | Object | task dependency | mutual exclusion with params | |
| 11 | maxRetryTimes | String | max retry times | ||
| 12 | retryInterval | String | retry interval | ||
| 13 | timeout | Object | timeout | ||
| 14 | taskInstancePriority | String | task priority | ||
| 15 | workerGroup | String | Worker group | ||
| 16 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"CONDITIONS",
"id":"tasks-96189",
"name":"条件",
"params":{
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
"test04"
],
"failedNode":[
"test05"
]
},
"dependence":{
"relation":"AND",
"dependTaskList":[
]
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
"test01",
"test02"
]
}
Subprocess Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task ID | ||
| 2 | type | String | task type | SHELL | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | processDefinitionId | Int | process definition ID | ||
| 6 | description | String | description | ||
| 7 | runFlag | String | execution flag | ||
| 8 | conditionResult | Object | condition branch | ||
| 9 | successNode | Array | jump to node if success | ||
| 10 | failedNode | Array | jump to node if failure | ||
| 11 | dependence | Object | task dependency | mutual exclusion with params | |
| 12 | maxRetryTimes | String | max retry times | ||
| 13 | retryInterval | String | retry interval | ||
| 14 | timeout | Object | timeout | ||
| 15 | taskInstancePriority | String | task priority | ||
| 16 | workerGroup | String | Worker group | ||
| 17 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"SUB_PROCESS",
"id":"tasks-14806",
"name":"SubProcessTask",
"params":{
"processDefinitionId":2
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
},
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}
DEPENDENT Node
The following shows the node data structure:
| No. | parameter name | type | description | notes | |
|---|---|---|---|---|---|
| 1 | id | String | task ID | ||
| 2 | type | String | task type | DEPENDENT | |
| 3 | name | String | task name | ||
| 4 | params | Object | customized parameters | JSON format | |
| 5 | rawScript | String | Shell script | ||
| 6 | localParams | Array | customized local parameters | ||
| 7 | resourceList | Array | resource files | ||
| 8 | description | String | description | ||
| 9 | runFlag | String | execution flag | ||
| 10 | conditionResult | Object | condition branch | ||
| 11 | successNode | Array | jump to node if success | ||
| 12 | failedNode | Array | jump to node if failure | ||
| 13 | dependence | Object | task dependency | mutual exclusion with params | |
| 14 | relation | String | relation | AND,OR | |
| 15 | dependTaskList | Array | dependent task list | ||
| 16 | maxRetryTimes | String | max retry times | ||
| 17 | retryInterval | String | retry interval | ||
| 18 | timeout | Object | timeout | ||
| 19 | taskInstancePriority | String | task priority | ||
| 20 | workerGroup | String | Worker group | ||
| 21 | preTasks | Array | preposition tasks |
Node data example:
{
"type":"DEPENDENT",
"id":"tasks-57057",
"name":"DenpendentTask",
"params":{
},
"description":"",
"runFlag":"NORMAL",
"conditionResult":{
"successNode":[
""
],
"failedNode":[
""
]
},
"dependence":{
"relation":"AND",
"dependTaskList":[
{
"relation":"AND",
"dependItemList":[
{
"projectId":1,
"definitionId":7,
"definitionList":[
{
"value":8,
"label":"MRTask"
},
{
"value":7,
"label":"FlinkTask"
},
{
"value":6,
"label":"SparkTask"
},
{
"value":5,
"label":"SqlTask-Update"
},
{
"value":4,
"label":"SqlTask-Query"
},
{
"value":3,
"label":"SubProcessTask"
},
{
"value":2,
"label":"Python Task"
},
{
"value":1,
"label":"Shell Task"
}
],
"depTasks":"ALL",
"cycle":"day",
"dateValue":"today"
}
]
},
{
"relation":"AND",
"dependItemList":[
{
"projectId":1,
"definitionId":5,
"definitionList":[
{
"value":8,
"label":"MRTask"
},
{
"value":7,
"label":"FlinkTask"
},
{
"value":6,
"label":"SparkTask"
},
{
"value":5,
"label":"SqlTask-Update"
},
{
"value":4,
"label":"SqlTask-Query"
},
{
"value":3,
"label":"SubProcessTask"
},
{
"value":2,
"label":"Python Task"
},
{
"value":1,
"label":"Shell Task"
}
],
"depTasks":"SqlTask-Update",
"cycle":"day",
"dateValue":"today"
}
]
}
]
},
"maxRetryTimes":"0",
"retryInterval":"1",
"timeout":{
"strategy":"",
"interval":null,
"enable":false
},
"taskInstancePriority":"MEDIUM",
"workerGroup":"default",
"preTasks":[
]
}