caishunfeng
2 years ago
committed by
GitHub
58 changed files with 718 additions and 1127 deletions
@ -0,0 +1,24 @@
|
||||
# DolphinScheduler Task Parameters Appendix |
||||
|
||||
DolphinScheduler task plugins share some common default parameters. Each type of task contains all or **some** default parameters as follows: |
||||
|
||||
## Default Task Parameters |
||||
|
||||
| **Parameter** | **Description** | |
||||
|--------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| |
||||
| Node Name | The name of the task. Node names within the same workflow must be unique. | |
||||
| Run Flag | Indicating whether to schedule the task. If you do not need to execute the task, you can turn on the `Prohibition execution` switch. | |
||||
| Description | Describing the function of this node. | |
||||
| Task Priority | When the number of the worker threads is insufficient, the worker executes task according to the priority. When two tasks have the same priority, the worker will execute them in `first come first served` fashion. | |
||||
| Worker Group | Machines which execute the tasks. If you choose `default`, scheduler will send the task to a random worker. | |
||||
| Task Group Name | Resource group of tasks. It will not take effect if not configured. | |
||||
| Environment Name | Environment to execute the task. | |
||||
| Number of Failed Retries | The number of task retries for failures. You could select it by drop-down menu or fill it manually. | |
||||
| Failure Retry Interval | Interval of task retries for failures. You could select it by drop-down menu or fill it manually. | |
||||
| CPU Quota | Assign the specified CPU time quota to the task executed. Takes a percentage value. Default -1 means unlimited. For example, the full CPU load of one core is 100%, and that of 16 cores is 1600%. You could configure it by [task.resource.limit.state](../../architecture/configuration.md). | |
||||
| Max Memory | Assign the specified max memory to the task executed. Exceeding this limit will trigger oom to be killed and will not automatically retry. Takes an MB value. Default -1 means unlimited. You could configure it by [task.resource.limit.state](../../architecture/configuration.md). | |
||||
| Timeout Alarm | Alarm for task timeout. When the task exceeds the "timeout threshold", an alarm email will send. | |
||||
| Delayed Execution Time | The time that a task delays for execution in minutes. | |
||||
| Resources | Resources which your task node uses. | |
||||
| Predecessor Task | The upstream task of the current task node. | |
||||
|
@ -0,0 +1,25 @@
|
||||
# DolphinScheduler任务参数附录 |
||||
|
||||
`DolphinScheduler`任务插件有一些公共参数,我们将这些公共参数列在文档中供您查阅。每种任务都有如下的所有或者**部分**默认参数: |
||||
|
||||
## 默认任务参数 |
||||
|
||||
| **任务参数** | **描述** | |
||||
|----------|--------------------------------------------------------------------------------------------------------------------------------------| |
||||
| 任务名称 | 任务的名称,同一个工作流定义中的节点名称不能重复。 | |
||||
| 运行标志 | 标识这个节点是否需要调度执行,如果不需要执行,可以打开禁止执行开关。 | |
||||
| 描述 | 当前节点的功能描述。 | |
||||
| 任务优先级 | worker线程数不足时,根据优先级从高到低依次执行任务,优先级一样时根据先到先得原则执行。 | |
||||
| Worker分组 | 设置分组后,任务会被分配给worker组的机器机执行。若选择Default,则会随机选择一个worker执行。 | |
||||
| 任务组名称 | 任务资源组,未配置则不生效。 | |
||||
| 组内优先级 | 一个任务组内此任务的优先级。 | |
||||
| 环境名称 | 配置任务执行的环境。 | |
||||
| 失败重试次数 | 任务失败重新提交的次数,可以在下拉菜单中选择或者手动填充。 | |
||||
| 失败重试间隔 | 任务失败重新提交任务的时间间隔,可以在下拉菜单中选择或者手动填充。 | |
||||
| CPU 配额 | 为执行的任务分配指定的CPU时间配额,单位为百分比,默认-1代表不限制,例如1个核心的CPU满载是100%,16个核心的是1600%。 [task.resource.limit.state](../../architecture/configuration.md) | |
||||
| 最大内存 | 为执行的任务分配指定的内存大小,超过会触发OOM被Kill同时不会进行自动重试,单位MB,默认-1代表不限制。该功能由 [task.resource.limit.state](../../architecture/configuration.md) 控制。 | |
||||
| 超时告警 | 设置超时告警、超时失败。当任务超过"超时时长"后,会发送告警邮件并且任务执行失败。该功能由 [task.resource.limit.state](../../architecture/configuration.md) 控制。 | |
||||
| 资源 | 任务执行时所需资源文件 | |
||||
| 前置任务 | 设置当前任务的前置(上游)任务。 | |
||||
| 延时执行时间 | 任务延迟执行的时间,以分为单位 | |
||||
|
@ -0,0 +1,42 @@
|
||||
# JAVA 节点 |
||||
|
||||
## 综述 |
||||
|
||||
该节点用于执行 java 类型的任务,支持使用单文件和jar包作为程序入口。 |
||||
|
||||
## 创建任务 |
||||
|
||||
- 点击项目管理 -> 项目名称 -> 工作流定义,点击”创建工作流”按钮,进入 DAG 编辑页面: |
||||
|
||||
- 拖动工具栏的JAVA任务节点到画板中。 |
||||
|
||||
## 任务参数 |
||||
|
||||
- 默认参数说明请参考[DolphinScheduler任务参数附录](appendix.md#默认任务参数)。 |
||||
|
||||
| **任务参数** | **描述** | |
||||
|----------|---------------------------------------------------------------| |
||||
| 模块路径 | 开启使用JAVA9+的模块化特性,把所有资源放入--module-path中,要求您的worker中的JDK版本支持模块化 | |
||||
| 主程序参数 | 作为普通Java程序main方法入口参数 | |
||||
| 虚拟机参数 | 配置启动虚拟机参数 | |
||||
| 脚本 | 若使用JAVA运行类型则需要编写JAVA代码。代码中必须存在public类,不用写package语句 | |
||||
| 资源 | 可以是外部JAR包也可以是其他资源文件,它们都会被加入到类路径或模块路径中,您可以在自己的JAVA脚本中轻松获取 | |
||||
|
||||
## 任务样例 |
||||
|
||||
java任务类型有两种运行模式,这里以JAVA模式为例进行演示。 |
||||
|
||||
主要配置参数如下: |
||||
|
||||
- 运行类型 |
||||
- 模块路径 |
||||
- 主程序参数 |
||||
- 虚拟机参数 |
||||
- 脚本文件 |
||||
|
||||
![java_task](../../../../img/tasks/demo/java_task02.png) |
||||
|
||||
## 注意事项 |
||||
|
||||
使用JAVA运行类型时代码中必须存在public类,可以不写package语句 |
||||
|
Loading…
Reference in new issue