|
1 | 1 | ---
|
2 | 2 | title: Apache Flink® job management in HDInsight on AKS
|
3 |
| -description: HDInsight on AKS provides a feature to manage and submit Apache Flink jobs directly through the Azure portal |
| 3 | +description: HDInsight on AKS provides a feature to manage and submit Apache Flink jobs directly through the Azure portal. |
4 | 4 | ms.service: hdinsight-aks
|
5 | 5 | ms.topic: tutorial
|
6 |
| -ms.date: 09/07/2023 |
| 6 | +ms.date: 04/01/2024 |
7 | 7 | ---
|
8 | 8 |
|
9 | 9 | # Apache Flink® job management in HDInsight on AKS clusters
|
@@ -79,11 +79,12 @@ Portal --> HDInsight on AKS Cluster Pool --> Flink Cluster --> Settings --> Flin
|
79 | 79 | | Entry class | Entry class for job from which job execution starts. | | Yes |
|
80 | 80 | | Args | Argument for main program of job. Separate all arguments with spaces. | | No |
|
81 | 81 | | parallelism | Job Flink Parallelism. | 2 | Yes |
|
82 |
| - | savepoint.directory | Savepoint directory for job. It is recommended that users should create a new directory for job savepoint in storage account. | `abfs://<container>@<account>/<deployment-ID>/savepoints` | No | |
| 82 | + | savepoint.directory | Savepoint directory for job. It's recommended that users should create a new directory for job savepoint in storage account. | `abfs://<container>@<account>/<deployment-ID>/savepoints` | No | |
| 83 | + |
83 | 84 |
|
84 | 85 | Once the job is launched, the job status on the portal is **RUNNING**.
|
85 | 86 |
|
86 |
| -- **Stop:** Stop job did not require any parameter, user can stop the job by selecting the action. |
| 87 | +- **Stop:** Stop job didn't require any parameter, user can stop the job by selecting the action. |
87 | 88 |
|
88 | 89 | :::image type="image" source="./media/flink-job-management/stop-job.png" alt-text="Screenshot shows how user can stop job." border="true" lightbox="./media/flink-job-management/stop-job.png":::
|
89 | 90 |
|
@@ -161,7 +162,7 @@ HDInsight on AKS supports user friendly ARM Rest APIs to submit job and manage j
|
161 | 162 |
|
162 | 163 | #### Base URL format for Rest API
|
163 | 164 |
|
164 |
| -See following URL for rest API, users need to replace subscription, resource group, cluster pool, cluster name and HDInsight on AKS API version in this before using it. |
| 165 | +See following URL for rest API, users need to replace subscription, resource group, cluster pool, cluster name, and HDInsight on AKS API version in this before using it. |
165 | 166 | `https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runjob?api-version={{API_VERSION}}`
|
166 | 167 |
|
167 | 168 | Using this REST API, users can initiate new jobs, stop jobs, start jobs, create savepoints, cancel jobs, and delete jobs. The current API_VERSION is 2023-06-01-preview.
|
@@ -233,7 +234,8 @@ To authenticate Flink ARM Rest API users, need to get the bearer token or acces
|
233 | 234 | |entryClass | Entry class for job from which job execution starts. | | Yes |
|
234 | 235 | | args | Argument for main program of job. Separate arguments with space. | | No |
|
235 | 236 | | parallelism | Job Flink Parallelism. | 2 | Yes |
|
236 |
| - | savepoint.directory | Savepoint directory for job. It is recommended that users should create a new directory for job savepoint in storage account. | `abfs://<container>@<account>/<deployment-ID>/savepoints`| No | |
| 237 | + | savepoint.directory | Savepoint directory for job. It's recommended that users should create a new directory for job savepoint in storage account. | `abfs://<container>@<account>/<deployment-ID>/savepoints`| No | |
| 238 | + |
237 | 239 |
|
238 | 240 | Example:
|
239 | 241 |
|
@@ -300,7 +302,8 @@ To authenticate Flink ARM Rest API users, need to get the bearer token or acces
|
300 | 302 | | jobType | Type of Job. It should be “FlinkJob” | Yes |
|
301 | 303 | | jobName | Job Name that is used for launching the job. | Yes |
|
302 | 304 | | action | It should be “START” | Yes |
|
303 |
| - | savePointName | Save point name to start the job. It is optional property, by default start operation take last successful savepoint. | No | |
| 305 | + | savePointName | Save point name to start the job. It's optional property, by default start operation take last successful savepoint. | No | |
| 306 | +
|
304 | 307 |
|
305 | 308 | **Example:**
|
306 | 309 |
|
@@ -337,7 +340,8 @@ To authenticate Flink ARM Rest API users, need to get the bearer token or acces
|
337 | 340 | | jobName | Job Name that is used for launching the job. | | Yes |
|
338 | 341 | | action | It should be “UPDATE” always for new job launch. | | Yes |
|
339 | 342 | | args | Job JVM arguments | | No |
|
340 |
| - | savePointName | Save point name to start the job. It is optional property, by default start operation will take last successful savepoint.| | No | |
| 343 | + | savePointName | Save point name to start the job. It's optional property, by default start operation will take last successful savepoint.| | No | |
| 344 | +
|
341 | 345 |
|
342 | 346 | Example:
|
343 | 347 |
|
|
0 commit comments