Skip to content

Commit 3ebbf12

Browse files
hanhan.zhangfuchanghai
authored andcommitted
add use case in doc
1 parent 43ef59e commit 3ebbf12

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

docs/docs/en/guide/task/flink.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ Flink task type, used to execute Flink programs. For Flink nodes:
2020

2121
- Please refer to [DolphinScheduler Task Parameters Appendix](appendix.md) `Default Task Parameters` section for default parameters.
2222

23-
| **Parameter** | **Description** |
23+
| **Parameter** | **Description** |
2424
|-------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
2525
| Program type | Support Java, Scala, Python and SQL four languages. |
2626
| Class of main function | The **full path** of Main Class, the entry point of the Flink program. |
@@ -37,7 +37,7 @@ Flink task type, used to execute Flink programs. For Flink nodes:
3737
| Parallelism | Used to set the degree of parallelism for executing Flink tasks. |
3838
| Yarn queue | Used to set the yarn queue, use `default` queue by default. |
3939
| Main program parameters | Set the input parameters for the Flink program and support the substitution of custom parameter variables. |
40-
| Optional parameters | Set the flink command options, such as `-D`, `-C`, `-yt`, and support the substitution of custom parameter variables. |
40+
| Optional parameters | Set the flink command options, such as `-D`, `-C`, `-yt`, and support the substitution of custom parameter variables, such as `-Dyarn.application.name=${job_name}` custom parameter job _name will be replaced. |
4141
| Custom parameter | It is a local user-defined parameter for Flink, and will replace the content with `${variable}` in the script. |
4242

4343
## Task Example

docs/docs/zh/guide/task/flink.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ Flink 任务类型,用于执行 Flink 程序。对于 Flink 节点:
2020

2121
- 默认参数说明请参考[DolphinScheduler任务参数附录](appendix.md)`默认任务参数`一栏。
2222

23-
| **任务参数** | **描述** |
23+
| **任务参数** | **描述** |
2424
|-----------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
2525
| 程序类型 | 支持 Java、Scala、 Python 和 SQL 四种语言 |
2626
| 主函数的 Class | Flink 程序的入口 Main Class 的**全路径** |
@@ -37,7 +37,7 @@ Flink 任务类型,用于执行 Flink 程序。对于 Flink 节点:
3737
| 并行度 | 用于设置执行 Flink 任务的并行度 |
3838
| Yarn 队列 | 用于设置 Yarn 队列,默认使用 default 队列 |
3939
| 主程序参数 | 设置 Flink 程序的输入参数,支持自定义参数变量的替换 |
40-
| 选项参数 | 设置Flink命令的选项参数,例如`-D`, `-C`, `-yt`,支持自定义参数变量的替换 |
40+
| 选项参数 | 设置Flink命令的选项参数,例如`-D`, `-C`, `-yt`,支持自定义参数变量的替换,例如`-Dyarn.application.name=${job_name}`,自定义参数job_name会被替换 |
4141
| 自定义参数 | 是 Flink 局部的用户自定义参数,会替换脚本中以 ${变量} 的内容 |
4242

4343
## 任务样例

0 commit comments

Comments
 (0)