Using DLI to Submit a Spark Jar Job

Scenario

DLI allows you to submit Spark jobs compiled as JAR files, which contain the necessary code and dependency information for executing the job. These files are used for specific data processing tasks such as data query, analysis, and machine learning. Before submitting a Spark Jar job, upload the package to OBS and submit it along with the data and job parameters to run the job.

This example introduces the basic process of submitting a Spark Jar job package through the DLI console. Due to different service requirements, the specific writing of the Jar package may vary. It is recommended that you refer to the sample code provided by DLI and edit and customize it according to your actual business scenario. Get DLI Sample Code.

Procedure

Table 1 describes the procedure for submitting a Spark Jar job using DLI.

Complete the preparations in Preparations before performing the following operations.

Preparations

• Register a Huawei ID and enable Huawei Cloud services. Make sure your account is not in arrears or frozen.
• Configure an agency for DLI.
  To use DLI, you need to access services such as Object Storage Service (OBS), Virtual Private Cloud (VPC), and Simple Message Notification (SMN). If it is your first time using DLI, you will need to configure an agency to allow access to these dependent services.

  1. Log in to the DLI management console using your account. In the navigation pane on the left, choose Global Configuration > Service Authorization.
  2. On the agency settings page, select the agency permissions under Basic Usage, Datasource, and O&M and click Update.
  3. View and understand the notes for updating the agency and click OK. The DLI agency permissions are updated.
     Figure 1 Configuring an agency for DLI
     
  4. Once configured, you can check the agency dli_management_agency in the agency list on the IAM console.

Step 1: Upload Data to OBS

Develop a Spark Jar job program by referring to Spark Job Sample Code, compile it, and pack it into spark-examples.jar. Perform the following steps to upload the program:

Before submitting Spark Jar jobs, upload data files to OBS.

1. Log in to the DLI console.
2. In the service list, click Object Storage Service under Storage.
3. Create a bucket. In this example, name it dli-test-obs01.
   1. On the displayed Buckets page, click Create Bucket in the upper right corner.
   2. On the displayed Create Bucket page, specify Region and enter the Bucket Name. Retain the default values for other parameters or set them as required.
      

      Select a region that matches the location of the DLI console.

   3. Click Create Now.
4. In the bucket list, click the name of the dli-test-obs01 bucket you just created to access its Objects tab.
5. Click Upload Object. In the dialog box displayed, drag or add files or folders, for example, spark-examples.jar, to the upload area. Then, click Upload.

   In this example, the path after upload is obs://dli-test-obs01/spark-examples.jar.

   For more operations on the OBS console, see the Object Storage Service User Guide.

Step 2: Create an Elastic Resource Pool and Add Queues to the Pool

Step 3: Use DEW to Manage Access Credentials

To write the output data of a Spark Jar job to OBS, AK/SK is required for accessing OBS. To ensure the security of AK/SK data, you can use Data Encryption Workshop (DEW) and Cloud Secret Management Service (CSMS) for unified management of AK/SK, effectively avoiding sensitive information leakage and business risks caused by hard-coded or plaintext configuration of programs.

Step 4: Create a Custom Agency to Allow DLI to Access DEW and Read Credentials

1. Log in to the management console.
2. In the upper right corner of the page, hover over the username and select Identity and Access Management.
3. In the navigation pane of the IAM console, choose Agencies.
4. On the displayed page, click Create Agency.
5. On the Create Agency page, set the following parameters:
   • Agency Name: Enter an agency name, for example, dli_dew_agency_access.
   • Agency Type: Select Cloud service.
   • Cloud Service: This parameter is available only when you select Cloud service for Agency Type. Select Data Lake Insight (DLI) from the drop-down list.
   • Validity Period: Select Unlimited.
   • Description: You can enter Agency with OBS OperateAccess permissions. This parameter is optional.
6. Click Next.
7. Click the agency name. On the displayed page, click the Permissions tab. Click Authorize. On the displayed page, click Create Policy.
8. Configure policy information.
   1. Enter a policy name, for example, dli-dew-agency.
   2. Select JSON.
   3. In the Policy Content area, paste a custom policy.

      {
          "Version": "1.1",
          "Statement": [
              {
                  "Effect": "Allow",
                  "Action": [
                      "csms:secretVersion:get",
                      "csms:secretVersion:list",
                      "kms:dek:decrypt"
                  ]
              }
          ]
      }

   4. Enter a policy description as required.
9. Click Next.
10. On the Select Policy/Role page, select Custom policy from the first drop-down list and select the custom policy created in 8.
11. Click Next. On the Select Scope page, set the authorization scope. In this example, select All resources.

    For details about authorization operations, see Creating a User Group and Assigning Permissions.

12. Click OK.

    It takes 15 to 30 minutes for the authorization to be in effect.

Step 5: Submit a Spark Job

1. On the DLI management console, choose Job Management > Spark Jobs in the navigation pane on the left. On the displayed page, click Create Job in the upper right corner.
2. Set the following Spark job parameters:
   • Queue: Select the queue created in Step 2: Create an Elastic Resource Pool and Add Queues to the Pool.
   • Spark Version: Select a Spark engine version. In this example, version 3.3.1 is selected.
   • Application: Select the package created in Step 1: Upload Data to OBS.
   • Agency: Select the agency created in Step 4: Create a Custom Agency to Allow DLI to Access DEW and Read Credentials, which is used to allow DLI to access the credentials stored in DEW.

   For other parameters, refer to the description about the Spark job editing page in Creating a Spark Job.

3. Click Execute in the upper right corner of the Spark job editing window, read and agree to the privacy agreement, and click OK. Submit the job. A message is displayed, indicating that the job is submitted.

   

4. (Optional) Switch to the Job Management > Spark Jobs page to view the status and logs of the submitted Spark job.
   

   When you click Execute on the DLI management console for the first time, you need to read the privacy agreement. Once agreed to the agreement, you will not receive any privacy agreement messages for subsequent operations.