HPC Cluster Job Scheduler

From HPC Docs
Jump to navigation Jump to search

This content is under construction. Check back often for updates.

Submitting Your First HPC Job

  1. Login to the HPC cluster using one of the methods described in on Accessing the Cluster via SSH on the Getting Started page.
  2. Make a directory using the command
    mkdir tutorial
    and then change into that directory using
    cd tutorial
  3. Next, make a copy of the submit script examples using
    cp /opt/tcnjhpc/esla-tutorial/examples/submit-* . 
    (make sure to include the . which represents the current directory as the target of the copy command).
  4. List the names of the files that were copied to the current directory.
    ls
  5. Edit one of the submission scripts to modify the email address in it. This email address will receive messages when the job starts and ends or if there was some kind of failure. Use the simple text editor nano to edit the file. Press CTRL q to quit nano.
    nano submit-mpi.sh
    You could alternately use the edit feature in Open OnDemand to make the change.
  6. Since the tutorial doesn't require any input file, you can simply submit this job to the cluster.
    sbatch submit-mpi.sh
  7. Monitor the status of your running job (which should only take about 20-25 seconds to run). The system will replace $USER in the command below with your username. You can also directly specify your username instead of $USER.
    squeue --user=$USER
  8. When your job ends, look for the additional file that was added to your directory.
    ls
    This file will be in the form of job.#####.out where the ##### matches the number in the JOBID column of the squeue command output. This creates unique output files which prevents subsequent job runs from overwriting previous outputs.
  9. You can view the job output file by running the command (replace ##### with the actual job ID)
    cat job.####.out


The video below demonstrates a sample run of the tutorial steps described above.

Anatomy of a SLURM Sbatch Submit Script

Sample MPI (Parallel) Sbatch Submission Script

We'll use this sample SLURM sbatch submission script below in our dissection.

#!/bin/bash

#SBATCH --workdir=./                     # Set the working directory
#SBATCH --mail-user=nobody@tcnj.edu      # Who to send emails to
#SBATCH --mail-type=ALL                  # Send emails on start, end and failure
#SBATCH --job-name=m_pi_dart             # Name to show in the job queue
#SBATCH --output=job.%j.out              # Name of stdout output file (%j expands to jobId)
#SBATCH --ntasks=10                      # Total number of mpi tasks requested
#SBATCH --nodes=2                        # Total number of nodes requested
#SBATCH --partition=short		 # Partition (a.k.a. queue) to use

module add elsa-tutorial

# Disable selection of Infiniband networking
export OMPI_MCA_btl=^openib

# Run MPI program
echo "Starting on "`date`
mpirun mdart 50000 10000
#              ^---- should be 500,000/ntasks to match serial version
echo "Finished on "`date`

The first line of the script must start with #! followed by the interpreter that the script will ultimately be fed to. In this case, and most commonly, it will be the /bin/bash shell.

#!/bin/bash

Normall the shell interpreter ignores # and anything that comes after it to the end of the line, but lines starting with #SBATCH will be interpreted by the sbatch command before being fed into the interpreter as specified above. Note: the line must START (no leading spaces) with exactly #SBATCH for it to be recognized by sbatch.

The --workdir option specifies the working directory. This will be the working directory where the job starts from (i.e., your job will cd to this directory before beginning).

The ./ represents the current directory which will be whatever directory you executed the sbatch command from. You could specify an absolute directory such as /home/hpc/ssivy/tutorial, but that would make the submission script less portable than what is used in this example.

#SBATCH --workdir=./                     # Set the working directory

The next two lines specify where job status messages should be emailed. If these lines are absent from your submissions script, no emails are sent. You should substitute your email address for nobody@tcnj.edu in the example. The mail-type of ALL tells the SLURM system to send emails when the job starts, ends or if there was a failure.

#SBATCH --mail-user=nobody@tcnj.edu      # Who to send emails to
#SBATCH --mail-type=ALL                  # Send emails on start, end and failure

The --job-name is simply the name you want to be visible in job listings, etc. such as output from the squeue command. It typically should not contain spaces (use - or _ instead of a space). If you insist on using spaces, the entire name must be enclosed in double quotes, e.g. #SBATCH --job-name="m pi dart".

#SBATCH --job-name=m_pi_dart             # Name to show in the job queue

The --output option specifies the file where any output that would normally go to the screen/terminal will be redirected. In the examlple, the %j will be replace with the job ID of the job. Each cluster job gets a unique ID. This format will allow multiple runs to create unique output files. It should be noted that this does not affect any files that are created from within your program. You need to figure that out using by reading its documentation.

#SBATCH --output=job.%j.out              # Name of stdout output file (%j expands to jobId)

The --ntasks specifies how many simultaneous tasks can be run by your program. This requires a program that understands MPI or a similar parallel processing method. This is basically the number of CPU processing cores you would like to allocate for your job. In this example, we are allocating 10 cores.

#SBATCH --ntasks=10                      # Total number of mpi tasks requested

A node is a discrete server in the HPC cluster. The --nodes option specifies how many server to allocate. The system will divide try to allocate an even number of tasks (from above) on each node. So, for this example, each node will be assigned 5 tasks if resources allow. If you program is not MPI or using some other parallel API (e.g. a serial program), it is a waste to request more than 1 node.

#SBATCH --nodes=2                        # Total number of nodes requested

In SLURM, a partition is what we call a group of nodes providing a similar function. Other schedulers may refer to partitions as queues. The --partition option specifies what SLURM parition or queue to assign the job to. Each partition has various settings (e.g. max job time) assigned to them. You can review the partition settings in the ELSA Job Partitions/Queues section below. If the --partition option is absent from your submission script, the SLURM default partition (short in the case of ELSA) will be used.

#SBATCH --partition=short		  # Partition (a.k.a. queue) to use

That marks the end of the sbatch options. The rest of the submission script are commands that will be run by the interpreter specified on the first line (/bin/bash in our example).

Typically, your submission script will have one or more module add lines to setup the environment for your application. Without these lines, you may get errors like command not found or messages about a missing libraries or other settings. The module command is part of the Lmod system used by the ELSA HPC cluster. You can find appropriate module add lines for various applications on the software page.

module add elsa-tutorial

The next lines are optional, but helps suppress any warning messages that you may see in our job output file about not being able to access the Infiniband network interface. Since not all nodes have Infiniband, you may or may not get this warning message depending on which nodes the SLURM schedule assigns to your job and if your program include the Infiniband libraries compiled in.

WARNING: There is at least non-excluded one OpenFabrics device found, but there are no active ports detected (or Open MPI was unable to use them).  This is most certainly not what you wanted.  Check your cables, subnet manager configuration, etc.  The openib BTL will be ignored for this job.

These are not errors and your job will still run fine, but some find these messages annoying.

Of course, you don't want these lines if you do want to use Infiniband since it basically tells the cluster not to use Infiniband even if it is available. See the constraints page for ways to specify how to guarantee your job has access to Infiniband.

# Disable selection of Infiniband networking
export OMPI_MCA_btl=^openib

These lines are optional, but the echo line is nice to have since it outputs the date/time of when your job started. It is up to you if you'd like this diagnostic info in your output.

# Run MPI program
echo "Starting on "`date`

All the magic happens here. This is where you specify your program(s) that will do the work. If your program is MPI-enabled you need to uses the mpirun launcher program. This will start multiple instances your your program as specified by the --ntasks and --nodes options above. It will also pass to the program various settings so it can understand the environment it is working in. If you are running a serial program, you would not specify the mpirun launcher. For example, if you were running the serial version of the dartboard program, you would just specify sdart 500000 10000.

mpirun mdart 50000 10000

Again these lines are optional and outputs the date/time of when your job finished.

#              ^---- should be 500,000/ntasks to match serial version
echo "Finished on "`date`

Sample Serial Sbatch Submission Script

#!/bin/bash

#SBATCH --workdir=./                     # Set the working directory
#SBATCH --mail-user=nobody@tcnj.edu      # Who to send emails to
#SBATCH --mail-type=ALL                  # Send emails on start, end and failure
#SBATCH --job-name=s_pi_dart             # Name to show in the job queue
#SBATCH --output=job.%j.out              # Name of stdout output file (%j expands to jobId)
#SBATCH --ntasks=1                       # Total number of mpi tasks requested
#SBATCH --nodes=1                        # Total number of nodes requested
#SBATCH --partition=short		 # Partition (a.k.a. queue) to use

module add elsa-tutorial

# Run serial program
echo "Starting on "`date`
sdart 500000 10000
echo "Finished on "`date`

Since most of the submission script will remains the same as the one above, let's focus on the differences.

With serial programs, they typically don't make use of multiple processing cores so it doesn't make sense to assign multiple tasks or multiple nodes. Some serial program can do multi-threading so you can try increasing the --ntasks option to see if it makes a performance difference.

#SBATCH --ntasks=1                       # Total number of mpi tasks requested
#SBATCH --nodes=1                        # Total number of nodes requested

As mentioned in the dissection above, when running serial programs, you do not specify the mpirun (sometimes also called mpiexec). Just specify the command like you would at a normal Linux command line.

sdart 500000 10000

Sample GPU Sbatch Submission Script

#!/bin/bash

#SBATCH --workdir=./                     # Set the working directory
#SBATCH --mail-user=nobody@tcnj.edu      # Who to send emails to
#SBATCH --mail-type=ALL                  # Send emails on start, end and failure
#SBATCH --job-name=g_pi_dart             # Name to show in the job queue
#SBATCH --output=job.%j.out              # Name of stdout output file (%j expands to jobId)
#SBATCH --ntasks=1                       # Total number of mpi tasks requested
#SBATCH --nodes=1                        # Total number of nodes requested
#SBATCH --partition=gpu			 # Partition (a.k.a. queue) to use
#SBATCH --gres=gpu:1			 # Select GPU resource (# after : indicates how many)

module add elsa-tutorial

# Run GPU program
echo "Starting on "`date`
gdart 500000 10000
echo "Finished on "`date`

Since most of the submission script will remains the same as the one above, let's focus on the differences.

With GPU programs, a good rule of thumb is to match the --ntasks with the number of GPUs specified in the --gres option (see more about that below). However, this is dependent on how much CPU parallelized the program supports. Some GPU programs are compiled with MPI support. In these cases, increasing the --ntasks and --nodes may be warranted.

#SBATCH --ntasks=1                       # Total number of mpi tasks requested

Of course, to have access to the nodes that contain GPUs, you need to specify a SLURM partition/queue that contains these types of nodes. Refer to xxx below for your options.

#SBATCH --partition=gpu			 # Partition (a.k.a. queue) to use

This line is required to allocate GPU(s) for your application. GRES stands for general resource. In this example we want a gpu resource and the number after the : specifies how many (1 in our example).

#SBATCH --gres=gpu:1			 # Select GPU resource (# after : indicates how many)

While this line it the same as the other examples, you may also require include a line to include CUDA library support. CUDA is the library that includes the code for GPU-enabled programs. In our example, the elsa-tutorial module automatically loads the CUDA module. If it didn't, you would need to add a line like module add cua in addition to the one listed.

module add elsa-tutorial

No special launcher is needed to run GPU-based applications. In this example, our GPU dartboard program is not compiled with MPI support. If it was, we would use mpirun gdart 500000 10000 to run it.

gdart 500000 10000

Advanced Submit Script Options

Constraints

The SLURM constraint option allows for further control over which nodes your job can be scheduled on in a particular parition/queue. You may require a specific processor family or network interconnect. The features that can be used with the sbatch constraint option are defined by the system administrator and thus vary among HPC sites.

One should be careful when combining multiple constraints. It is possible to specify a combination that cannot be satisfied (e.g. specifying a node with a skylake and a broadwell family of processor).

Available ELSA HPC constraints.

Example 1 (single constraint):

#SBATCH --constraint=skylake

Example 2 (anding multiple constraints):

#SBATCH --constraint="skylake&ib"

Example 3 (oring multiple constraints):

#SBATCH --constraint="skylake|broadwell"

Example 3 (complex constraints):

#SBATCH --constraint="(skylake|broadwell)&ib"

Node Exclusivity

The job allocation can not share nodes with other running jobs.

This option should be used judiciously and sparingly. If for example, your job requires only 2 CPU cores and is scheduled on a node with 32 cores, no other job will be able to make use of the remaining 30 cores (not even your own job). Where this may make sense is when your job is competing for memory (RAM) with others running on the same node. The system is not yet configured to enforce memory limitations like it does for CPU cores. Using this option will guarantee that the entire node is exclusive to your job.

Example:

#SBATCH --exclusive

Job Arrays

Example 1:

#SBATCH --output=job.%A_%a.out
#SBATCH --array=1-100

Example 2 (step size):

#SBATCH --output=job.%A_%a.out
#SBATCH --array=1-100:20

Example 3 (limit simultaneous task):

#SBATCH --output=job.%A_%a.out
#SBATCH --array=1-100%5

Example Submit Scripts

Content to be created.

ELSA Job Partitions/Queues

Parition/Queue Name Max Time Limit Resource Type
short 6 hours CPU
normal 24 hours CPU
long 7 days CPU
nolimit* none CPU
shortgpu 6 hours GPU
gpu 7 days GPU

* - Use of the nolimit partition is restricted to approved cluster users. Faculty may request access for themselves and students by emailing ssivy@tcnj.edu.