|
|
|
@ -21,7 +21,7 @@ Flink task type, used to execute Flink programs. For Flink nodes:
|
|
|
|
|
- Please refer to [DolphinScheduler Task Parameters Appendix](appendix.md) `Default Task Parameters` section for default parameters. |
|
|
|
|
|
|
|
|
|
| **Parameter** | **Description** | |
|
|
|
|
|-------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---| |
|
|
|
|
|-------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| |
|
|
|
|
| Program type | Support Java, Scala, Python and SQL four languages. | |
|
|
|
|
| Class of main function | The **full path** of Main Class, the entry point of the Flink program. | |
|
|
|
|
| Main jar package | The jar package of the Flink program (upload by Resource Center). | |
|
|
|
@ -36,7 +36,7 @@ Flink task type, used to execute Flink programs. For Flink nodes:
|
|
|
|
|
| Number of TaskManager | Used to set the number of taskManagers, which can be set according to the actual production environment. | |
|
|
|
|
| Parallelism | Used to set the degree of parallelism for executing Flink tasks. | |
|
|
|
|
| Main program parameters | Set the input parameters for the Flink program and support the substitution of custom parameter variables. | |
|
|
|
|
| Optional parameters | Support `--jar`, `--files`,` --archives`, `--conf` format. | | |
|
|
|
|
| Optional parameters | Support `--jar`, `--files`,` --archives`, `--conf` format. | |
|
|
|
|
| Custom parameter | It is a local user-defined parameter for Flink, and will replace the content with `${variable}` in the script. | |
|
|
|
|
|
|
|
|
|
## Task Example |
|
|
|
|