Managing Jobs on the Flink Web UI

Scenario

Define Flink jobs, including Flink SQL and Flink JAR jobs.

Creating a Job

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. Click Create Job. On the displayed job creation page, set parameters by referring to Table 1 and click OK. The job development page is displayed.

   Table 1 Parameters for creating a job

   Parameter	Description
   Type	Job type, which can be Flink SQL or Flink Jar.
   Name	Job name, which can contain a maximum of 64 characters. Only letters, digits, and underscores (_) are allowed.
   Task Type	Type of the job data source, which can be a stream job or a batch job.
   Description	Job description, which can contain a maximum of 100 characters.

4. (Optional) If you need to develop a job immediately, configure the job on the job development page.
   • Creating a Flink SQL job
     1. Develop the job on the job development page.

     2. Click Check Semantic to check the input content and click Format SQL to format SQL statements.
     3. After the job SQL statements are developed, set basic and customized parameters as required by referring to Table 2 and click Save.

        Table 2 Basic parameters

        Parameter	Description
        Parallelism	Number of concurrent jobs. The value must be a positive integer containing a maximum of 64 characters.
        Maximum Operator Parallelism	Maximum parallelism of operators. The value must be a positive integer containing a maximum of 64 characters.
        JobManager Memory (MB)	Memory of JobManager The minimum value is 512 and the value can contain a maximum of 64 characters.
        Submit Queue	Queue to which a job is submitted. If this parameter is not set, the default queue is used. The queue name can contain a maximum of 30 characters. Only letters, digits, and underscores (_) are allowed.
        taskManager	taskManager running parameters include: Slots: If this parameter is left blank, the default value 1 is used. Memory (MB): The minimum value is 512.
        Enable CheckPoint	Whether to enable CheckPoint. After CheckPoint is enabled, you need to configure the following information: Time Interval (ms): This parameter is mandatory. Mode: This parameter is mandatory. The options are EXACTLY_ONCE and AT_LEAST_ONCE. Minimum Interval (ms): The minimum value is 10. Timeout Duration: The minimum value is 10. Maximum Parallelism: The value must be a positive integer containing a maximum of 64 characters. Whether to clean up: This parameter can be set to Yes or No. Whether to enable incremental checkpoints: This parameter can be set to Yes or No.
        Failure Recovery Policy	Failure recovery policy of a job. The options are as follows: fixed-delay: You need to configure Retry Times and Retry Interval (s). failure-rate: You need to configure Max Retry Times, Interval (min), and Retry Interval (s). none

     4. Click Submit in the upper left corner to submit the job.
   • Creating a Flink JAR job
     1. Click Select to upload a local JAR file and set parameters by referring to Table 3 or add customized parameters.

        Table 3 Parameter configuration

        Parameter	Description
        Local .jar File	Upload a local JAR file. The size of the file cannot exceed 10 MB.
        Main Class	Main-Class type. Default: By default, the class name is specified based on the Mainfest file in the JAR file. Specify: Manually specify the class name.
        Type	Class name. This parameter is available when Main Class is set to Specify.
        Class Parameter	Class parameters of Main-Class (parameters are separated by spaces).
        Parallelism	Number of concurrent jobs. The value must be a positive integer containing a maximum of 64 characters.
        JobManager Memory (MB)	Memory of JobManager The minimum value is 512 and the value can contain a maximum of 64 characters.
        Submit Queue	Queue to which a job is submitted. If this parameter is not set, the default queue is used. The queue name can contain a maximum of 30 characters. Only letters, digits, and underscores (_) are allowed.
        taskManager	taskManager running parameters include: Slots: If this parameter is left blank, the default value 1 is used. Memory (MB): The minimum value is 512.

     2. Click Save to save the configuration and click Submit to submit the job.

5. Return to the job management page. You can view information about the created job, including job name, type, status, kind, and description.
   

   To read files related to the submitted job on the node as another user, ensure that the user and the user who submitted the job belong to the same user group and the user has been assigned the FlinkServer application management role. For example,application view is selected by referring to Authentication Based on Users and Roles.

Starting a Job

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the job to be started, click Start to run the job. Jobs in the Draft, Saved, Submission failed, Running succeeded, Running failed, or Stop state can be started.

Developing a Job

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the job to be developed, click Develop to go to the job development page. Develop a job by referring to 4. You can view created stream tables and fields in the list on the left.

Editing the Job Name and Description

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the item to be modified, click Edit, modify Description, and click OK to save the modification.

Viewing Job Details

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the item to be viewed, choose More > Job Monitoring to view the job running details.
   

   You can only view details about jobs in the Running state.

Checkpoint Failure Recovery

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the item to be restored, click More > Checkpoint Failure Recovery. You can perform checkpoint failure recovery for jobs in the Running failed, Running Succeeded, or Stop state.

Filtering/Searching for Jobs

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the upper right corner of the page, you can obtain job information by selecting the job name, or enter a keyword to search for a job.

Stopping a Job

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the item to be stopped, click Stop. Jobs in the Submitting, Submission succeeded, or Running state can be stopped.

Deleting a Job

1. Access the Flink web UI. For details, see Accessing the Flink Web UI.
2. Click Job Management. The job management page is displayed.
3. In the Operation column of the item to be deleted, click Delete, and click OK in the displayed page. Jobs in the Draft, Saved, Submission failed, Running succeeded, Running failed, or Stop state can be deleted.