Apache Mesos - Quota

Quota

A problem when running multiple frameworks on Mesos is that the default wDRF allocator may offer resources to frameworks even though they are beyond their fair share (e.g., when no other framework currently accepts these resources). There is no mechanism to lay away resources for future consumption in an entire cluster. Even though dynamic reservations allow both operators and frameworks to dynamically reserve resources on particular Mesos agents, it does not solve the above problem because any individual agents might fail.

Mesos 0.27 introduced support for quotas, which are a mechanism for guaranteeing that a role will receive a certain minimum amount of resources. A quota specifies a minimum amount of resources that the role is guaranteed to receive (unless the total resources in the cluster are less than the configured quota resources, which often indicates a misconfiguration). Of course, the role might receive offers for more resources than its configured quota, as dictated by the default Mesos DRF allocation scheme.

Quotas are somewhat similar to reserved resources, but they have several differences. Most importantly, quota resources are not tied to a particular agent—that is, a quota ensures that a role will receive a certain amount of resources somewhere in the cluster, whereas reservations can be used to assign specific resources at a particular agent to a given role. Quotas can only be configured by operators, via the HTTP endpoint described below; dynamic reservations can be made by frameworks, provided the framework’s principal is authorized to make reservations.

Note that reserved resources are considered to satisfy a role’s quota. For example, if a role has been assigned a quota of 4 CPUs and also has 2 reserved resources at a particular agent, the role has a minimum guarantee of 4 CPUs, not 6.

Terminology

For the purpose of this document, an “Operator” is a person, tool, or script that manages the Mesos cluster.

In computer science, a “quota” usually refers to one of the following:

In Mesos, a quota is a guaranteed resource allocation that a role may rely on; in other words, a minimum share a role is entitled to receive.

NOTE: The built-in wDRF allocator extends this contract, and based on the definition above, treats quota as the pair of both the minimal and maximal share a role is entitled to receive. See wDRF implementation notes for details.

Motivation and Limitations

Consider the following scenarios in a Mesos cluster to better understand which use-cases are supported by quota, and which are not.

Scenario 1: Greedy Framework

There are two frameworks in a cluster, each are subscribed to their own distinct role, and both roles have equal weights: framework fA subscribed to role rA and framework fB subscribed to role rB. There is a single resource available in the cluster: 100 CPUs. fA consumes 10 CPUs and is idle (declines resource offers), while fB is greedy and accepts all offers it gets, hogging the remaining 90 CPUs. Without quota, though fA’s fair share is 50 CPUs it will not be able to make use of additional the 40 CPUs until some of fB’s tasks terminate.

Scenario 2: Resources for a new Framework

A greedy framework fB subscribed to role rB is currently the only framework in the cluster and it uses all available resources—100 CPUs. If a new framework fA subscribed to role rA joins the cluster, it will not receive its fair share of the cluster resources (50 CPUs) until some of fB’s tasks terminate.

To deal with Scenario 2, quota by itself is not a sufficient solution as it would be set after fB has started using all resources. Instead Scenario 2 requires either always keeping a pool of resources which are not offered or introducing preemption for running tasks.

Operator HTTP Endpoint

The master /quota HTTP endpoint enables operators to configure quotas. The endpoint currently offers a REST-like interface and supports the following operations:

Currently it is not possible to update previously configured quotas. This means in order to update a quota for a given role, the operator has to remove the existing quota and then set a new one.

The endpoint can optionally use authentication and authorization. See authentication guide for details.

### Set

The operator can set a new quota by sending an HTTP POST request to the /quota endpoint.

An example request to the quota endpoint could look like this (using the JSON file below):

 $ curl -d @quota.json -X POST http://<master-ip>:<port>/quota

For example to set a quota of 12 CPUs and 6144 MB of RAM for role1 the operator can use the following quota.json:

 {
   "role": "role1",
   "guarantee": [
     {
       "name": "cpus",
       "type": "SCALAR",
       "scalar": { "value": 12 }
     },
     {
       "name": "mem",
       "type": "SCALAR",
       "scalar": { "value": 6144 }
     }
   ]
 }

A set request is only valid for roles for which no quota is currently set. However if the master is configured without an explicit role whitelist, a set request can introduce new roles.

In order to bypass the capacity heuristic check the operator should set an optional force field:

 {
   "force": true,
   "role": "role1",
   ...
 }

The operator will receive one of the following HTTP response codes:

### Remove

The operator can remove a previously set quota by sending an HTTP DELETE request to the /quota/<role> endpoint. For example the following command removes a previously set quota for role1:

 $ curl -X DELETE http://<master-ip>:<port>/quota/role1

The operator will receive one of the following HTTP response codes:

### Status

The operator can query the configured quotas by sending an HTTP GET request to the /quota endpoint.

 $ curl -X GET http://<master-ip>:<port>/quota

The response message body includes a JSON representation of the current quota status for role(s) which principal is authorized to query quota status (if authorization is enabled). For example:

 {
   "infos": [
     {
       "role": "role1",
       "guarantee": [
         {
           "name": "cpus",
           "role": "*",
           "type": "SCALAR",
           "scalar": { "value": 12 }
         },
         {
           "name": "mem",
           "role": "*",
           "type": "SCALAR",
           "scalar": { "value": 6144 }
         }
       ]
     }
   ]
 }

The operator will receive one of the following HTTP response codes:

NOTE: If the principal is not authorized to query quota status for certain role(s), the result will not include corresponding quota information.

How Does It Work?

There are several stages in the lifetime of a quota issued by operator. First the quota set request is handled by the master, after that the allocator enforces the quota. Quotas can be removed by the operator.

It is important to understand that the enforcement of quota depends on the allocator being used. A custom allocator could choose to handle quota in its own way or even to ignore quota. The following section assumes the default wDRF allocator is used.

Be aware that setting quota may affect other frameworks in the cluster, because resources will be laid away and not offered to other frameworks. Also note, that quota is only applicable for scalar resources (e.g., it is not possible to set quota for port resources).

## Quota Request Processing

When an operator submits a quota set request via the master /quota HTTP endpoint, the following steps are triggered:

  1. Authenticate the HTTP request.
  2. Parse and validate the request. See description of possible error codes.
  3. Authorize the HTTP request if authorization is enabled.
  4. Run the capacity heuristic if not disabled by the force flag.
  5. Reliably store quota. See details on failover recovery.
  6. Rescind outstanding offers.

The quota remove request processing is simpler and triggers the following steps:

  1. Authenticate the HTTP request.
  2. Validate the request. See description of potential error codes.
  3. Authorize the HTTP request if authorization is enabled.
  4. Reliably remove quota.

### Capacity Heuristic Check

Misconfigured quota can render a cluster into a state where no offers are made to any frameworks. For example imagine an operator setting quota 1000 CPUs for a role prosuction (note the typo) in a cluster with a total capacity of 100 CPUs. In that case after the quota is accepted by the master, no offers will be made to any framework in any actual role (including production).

In order to prevent such extreme situations, the Mesos Master employs a capacity heuristic check that ensures a quota set request can reasonably be satisfied given the total cluster capacity. This heuristic tests whether the total quota, including the new request, does not exceed the sum of total non-statically-reserved cluster resources, i.e. the following inequality holds:

 total resources - statically reserved >= total quota + quota request

Please be advised that even if there are enough resources at the moment of this check, agents may terminate at any time, rendering the cluster incapable of satisfying the configured quotas.

A force flag can be set to bypass this check. For example, this flag can be useful when the operator would like to configure a quota that exceeds the current cluster capacity, but they know that additional cluster resources will be added shortly.

### Rescinding Outstanding Offers

When setting a new quota, the master rescinds outstanding offers. This avoids situations where the quota request cannot be satisfied by the remaining unoffered resources, but there are enough resources tied up in outstanding offers to frameworks that have not accepted them yet. Hence, we rescind outstanding offers with the following rules:

## Enforcement by wDRF Allocator

The wDRF allocator first allocates (or lays away if offers are declined) resources to roles with quota set. Once all quotas are satisfied, it proceeds with the standard wDRF for all remaining roles.

NOTE: A quota’ed role may not be allocated any unreserved non-revocable resources beyond its quota guarantee. If frameworks in the quota’ed role have not opted for revocable resources, they may stop getting offers once quota for the role is satisfied. In this case setting quota to any value that is less than the role’s fair share may reduce the amount of resources offered to this role.

NOTE: Currently quota guarantee also serves as quota limit, i.e. once quota for the role is satisfied, no further resources will be offered to the role except those reserved for the role. This behavior aims to mitigate the absence of quota limit and will be changed in future releases.

NOTE: Prior to Mesos 1.5, the allocator would allocate the entire available resources on an agent (including the resources that the role has no quota for) when trying to satisfy the quota of a role i.e. the quota allocation was coarse-grained. This has been fixed in Mesos 1.5. Specially, the allocator follows the steps below when allocating resources on an agent to a quota role:

If there are multiple frameworks subscribed to a role with quota set, the standard wDRF algorithm determines offer precedence amongst these frameworks.

The default wDRF allocator considers only non-revocable resources as applicable towards quota.

## Failover

If there is at least one role with quota set, the master failover recovery changes significantly. The reason for this is that during the recovery there is a period of time when not all agents have registered with the Master. Therefore it is impossible to reason about whether all quotas are satisfied.

To address this issue, if upon recovery any previously set quota are detected, the allocator enters recovery mode, during which the allocator does not issue offers. The recovery mode—and therefore offer suspension—ends when either:

Current Limitations