Run MapReduce jobs with Hadoop on HDInsight using REST

Learn how to use the WebHCat REST API to run MapReduce jobs on a Hadoop on HDInsight cluster. Curl is used to demonstrate how you can interact with HDInsight by using raw HTTP requests to run MapReduce jobs.


If you are already familiar with using Linux-based Hadoop servers, but you are new to HDInsight, see the What you need to know about Linux-based Hadoop on HDInsight document.


  • A Hadoop on HDInsight cluster
  • Curl
  • jq

Run MapReduce jobs using Curl


When you use Curl or any other REST communication with WebHCat, you must authenticate the requests by providing the HDInsight cluster administrator user name and password. You must use the cluster name as part of the URI that is used to send the requests to the server.

For the commands in this section, replace admin with the user to authenticate to the cluster. Replace CLUSTERNAME with the name of your cluster. When prompted, provide the password for the user account.

The REST API is secured by using basic access authentication. You should always make requests by using HTTPS to ensure that your credentials are securely sent to the server.

  1. From a command line, use the following command to verify that you can connect to your HDInsight cluster:

    curl -u admin -G

    You receive a response similar to the following JSON:


    The parameters used in this command are as follows:

    • -u: Indicates the user name and password used to authenticate the request
    • -G: Indicates that this operation is a GET request

    The beginning of the URI,, is the same for all requests.

  2. To submit a MapReduce job, use the following command:

    curl -u admin -d -d jar=/example/jars/hadoop-mapreduce-examples.jar -d class=wordcount -d arg=/example/data/gutenberg/davinci.txt -d arg=/example/data/CurlOut

    The end of the URI (/mapreduce/jar) tells WebHCat that this request starts a MapReduce job from a class in a jar file. The parameters used in this command are as follows:

    • -d: -G is not used, so the request defaults to the POST method. -d specifies the data values that are sent with the request.
      • The user who is running the command
      • jar: The location of the jar file that contains class to be ran
      • class: The class that contains the MapReduce logic
      • arg: The arguments to be passed to the MapReduce job. In this case, the input text file and the directory that are used for the output

    This command should return a job ID that can be used to check the status of the job:

  3. To check the status of the job, use the following command:

    curl -G -u admin -d | jq .status.state

    Replace the JOBID with the value returned in the previous step. For example, if the return value was {"id":"job_1415651640909_0026"}, then the JOBID would be job_1415651640909_0026.

    If the job is complete, the state returned is SUCCEEDED.


    This Curl request returns a JSON document with information about the job. Jq is used to retrieve only the state value.

  4. When the state of the job has changed to SUCCEEDED, you can retrieve the results of the job from Azure Blob storage. The statusdir parameter that is passed with the query contains the location of the output file. In this example, the location is /example/curl. This address stores the output of the job in the clusters default storage at /example/curl.

You can list and download these files by using the Azure CLI 2.0. For more information on working with blobs from the Azure CLI, see the Using the Azure CLI 2.0 with Azure Storage document.

Next steps

For general information about MapReduce jobs in HDInsight:

For information about other ways you can work with Hadoop on HDInsight:

For more information about the REST interface that is used in this article, see the WebHCat Reference.