Contact UsGet started
© 2024 Direct Cursus Technology L.L.C.

Managing Spark jobs

Written by
Updated at December 16, 2024

Create a job

  1. Go to the folder page and select Yandex Data Processing.

  2. Click the cluster name and open the Jobs tab.

  3. Click Submit job.

  4. (Optional) Enter a name for the job.

  5. In the Job type field, select Spark.

  6. In the Main jar field, specify the path to the main JAR application file in the following format:

    File Path format
    Instance file system file:///<path_to_file>
    Distributed cluster file system hdfs:///<path_to_file>
    Bucket Object Storage s3a://<bucket_name>/<path_to_file>
    Internet http://<path_to_file> or https://<path_to_file>

    Archives in standard Linux formats, such as zip, gz, xz, bz2, and others, are supported.

    The cluster service account needs read access to all the files in the bucket. For step-by-step guides on setting up access to Object Storage, see Editing a bucket's ACL.

  7. In the Main class field, specify the name of the main application class.

  8. Specify job arguments.

    If an argument, variable, or property is in several space-separated parts, specify each part separately. At the same time, it is important to preserve the order in which you declare arguments, variables, and properties.

    The -mapper mapper.py argument, for instance, must be converted into two arguments: -mapper and mapper.py in that order.

  9. (Optional) Specify the paths to the JAR files, if any.

  10. (Optional) Configure advanced settings:

    • Specify paths to the required files and archives.
    • In the Properties field, specify component properties as key-value pairs.

  11. Click Submit job.

If you do not have the Yandex Cloud command line interface yet, install and initialize it.

The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name or --folder-id parameter.

To create a job:

  1. View a description of the CLI create command for spark jobs:

    yc dataproc job create-spark --help

  2. Create a job (the example does not show all the available parameters):

    yc dataproc job create-spark \
   --cluster-name=<cluster_name> \
   --name=<job_name> \
   --main-class=<name_of_main_application_class> \
   --main-jar-file-uri=<path_to_main_jar_file> \
   --jar-file-uris=<path_to_jar_file> \
   --file-uris=<path_to_file> \
   --archive-uris=<path_to_archive> \
   --properties=<component_properties> \
   --args=<arguments> \
   --packages=<Maven_coordinates_of_jar_files> \
   --repositories=<additional_repositories> \
   --exclude-packages=<packages_to_exclude>

    Where:

    • --properties: Component properties as key-value pairs.
    • --args: Arguments passed to the job.
    • --packages: Maven coordinates of JAR files as groupId:artifactId:version.
    • --repositories: Additional repositories to search for packages.
    • --exclude-packages: Packages to exclude as groupId:artifactId.

    Provide the paths to the files required for the job in the following format:

    File Path format
    Instance file system file:///<path_to_file>
    Distributed cluster file system hdfs:///<path_to_file>
    Bucket Object Storage s3a://<bucket_name>/<path_to_file>
    Internet http://<path_to_file> or https://<path_to_file>

    Archives in standard Linux formats, such as zip, gz, xz, bz2, and others, are supported.

    The cluster service account needs read access to all the files in the bucket. For step-by-step guides on setting up access to Object Storage, see Editing a bucket's ACL.

You can get the cluster ID and name with a list of clusters in the folder.

Use the create API method and include the following information in the request:

  • Cluster ID in the clusterId parameter.
  • Job name in the name parameter.
  • Job properties in the sparkJob parameter.

You can get the cluster ID with a list of clusters in the folder.

Cancel a job

Note

You cannot cancel jobs with the status ERROR, DONE, or CANCELLED. To find out a job's status, retrieve a list of jobs in the cluster.

  1. Go to the folder page and select Yandex Data Processing.
  2. Click the cluster name and open the Jobs tab.
  3. Click the job name.
  4. Click Cancel in the top-right corner of the page.
  5. In the window that opens, select Cancel.

If you do not have the Yandex Cloud command line interface yet, install and initialize it.

The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name or --folder-id parameter.

To cancel a job, run the command below:

yc dataproc job cancel <job_name_or_ID> \
  --cluster-name=<cluster_name>

You can get the job name or ID with the list of cluster jobs, and the cluster name, with the list of folder clusters.

Use the API cancel method and include the following in the request:

  • Cluster ID in the clusterId parameter.
  • Job ID in the jobId parameter.

You can get the cluster ID with the list of folder clusters, and the job ID, with the list of cluster jobs.

Get a list of jobs

  1. Go to the folder page and select Yandex Data Processing.
  2. Click the cluster name and open the Jobs tab.

If you do not have the Yandex Cloud command line interface yet, install and initialize it.

The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name or --folder-id parameter.

To get a list of jobs, run the following command:

yc dataproc job list --cluster-name=<cluster_name>

You can get the cluster ID and name with a list of clusters in the folder.

Use the list API method and provide the cluster ID in the clusterId request parameter.

You can get the cluster ID with a list of clusters in the folder.

Get general information about the job

  1. Go to the folder page and select Yandex Data Processing.
  2. Click the cluster name and open the Jobs tab.
  3. Click the job name.

If you do not have the Yandex Cloud command line interface yet, install and initialize it.

The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name or --folder-id parameter.

To get general information about the job, run the command:

yc dataproc job get \
   --cluster-name=<cluster_name> \
   --name=<job_name>

You can get the cluster ID and name with a list of clusters in the folder.

Use the get API method and include the following in the request:

Get job execution logs

Note

You can view the job logs and search data in them using Yandex Cloud Logging. For more information, see Working with logs.

  1. Go to the folder page and select Yandex Data Processing.
  2. Click the cluster name and open the Jobs tab.
  3. Click the job name.

If you do not have the Yandex Cloud command line interface yet, install and initialize it.

The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name or --folder-id parameter.

To get job execution logs, run the following command:

yc dataproc job log \
   --cluster-name=<cluster_name> \
   --name=<job_name>

You can get the cluster ID and name with a list of clusters in the folder.

Use the API listLog method and include the following in the request:

Previous
Running jobs
Next
PySpark jobs