Edit

Share via

Failure spark job debugging with Azure Toolkit for IntelliJ (preview)

  • Article

This article provides step-by-step guidance on how to use HDInsight Tools in Azure Toolkit for IntelliJ to run Spark Failure Debug applications.

Prerequisites

Create a project with debugging template

Create a spark2.3.2 project to continue failure debug, take failure task​ debugging sample file in this document.

  1. Open IntelliJ IDEA. Open the New Project window.

    a. Select Azure Spark/HDInsight from the left pane.

    b. Select Spark Project with Failure Task Debugging Sample(Preview)(Scala) from the main window.

    Intellij Create a debug project.

    c. Select Next.

  2. In the New Project window, do the following steps:

    Intellij New Project select Spark version.

    a. Enter a project name and project location.

    b. In the Project SDK drop-down list, select Java 1.8 for Spark 2.3.2 cluster.

    c. In the Spark Version drop-down list, select Spark 2.3.2(Scala 2.11.8).

    d. Select Finish.

  3. Select src > main > scala to open your code in the project. This example uses the AgeMean_Div() script.

Run a Spark ​Scala/Java application on an HDInsight cluster

Create a spark Scala​/Java application, then run the application on a Spark cluster by doing the following steps:

  1. Click Add Configuration to open Run/Debug Configurations window.

    HDI Intellij Add configuration.

  2. In the Run/Debug Configurations dialog box, select the plus sign (+). Then select the Apache Spark on HDInsight option.

    Intellij Add new configuration.

  3. Switch to Remotely Run in Cluster tab. Enter information for Name, Spark cluster, and Main class name. Our tools support debug with Executors. The numExectors, the default value is 5, and you'd better not set higher than 3. To reduce the run time, you can add spark.yarn.maxAppAttempts into job Configurations and set the value to 1. Click OK button to save the configuration.

    Intellij Run debug configurations new.

  4. The configuration is now saved with the name you provided. To view the configuration details, select the configuration name. To make changes, select Edit Configurations.

  5. After you complete the configurations settings, you can run the project against the remote cluster.

    Intellij Debug Remote Spark Job Remote run button.

  6. You can check the application ID from the output window.

    Intellij Debug Remote Spark Job Remote run result.

Download failed job profile

​If the job submission fails, you could download the failed job profile to the local machine for further debugging.

  1. Open Microsoft Azure Storage Explorer, locate the HDInsight account of the cluster for the failed job, download the failed job resources from the corresponding location: \hdp\spark2-events\.spark-failures\<application ID> to a local folder.​ The activities window will show the download progress.

    Azure Storage Explorer download failure.

    Azure Storage Explorer download success.

Configure local debugging environment and debug on failure​​

  1. Open the original project​ or create a new project and associate it with the original source code​.​ Only spark2.3.2 version is supported for failure debugging currently.

  2. In IntelliJ IDEA, create a Spark Failure Debug config file, select the FTD file from the previously downloaded failed job resources for the Spark Job Failure Context location field.

    crete failure configuration.

  3. Click the local run button in the toolbar, the error will display in Run window.

    run-failure-configuration1.

    run-failure-configuration2.

  4. Set break point as the log indicates, then click local debug button to do local debugging just as your normal Scala / Java projects in IntelliJ.

  5. After debugging, ​if the project completes successfully​​​, ​you could resubmit the failed job to your spark on HDInsight cluster.

Next steps

Scenarios

Create and run applications

Tools and extensions

Manage resources