scheduler
Contains information and status for scheduling nodes residing on the local server. This table can be used for monitoring. The table contains a row for every scheduling node.
Example:
SELECT *
FROM system.scheduler
WHERE resource = 'network_read' AND path = '/prio/fair/prod'
FORMAT Vertical
Row 1:
──────
resource: network_read
path: /prio/fair/prod
type: fifo
weight: 5
priority: 0
is_active: 0
active_children: 0
dequeued_requests: 67
canceled_requests: 0
dequeued_cost: 4692272
canceled_cost: 0
busy_periods: 63
vruntime: 938454.1999999989
system_vruntime: ᴺᵁᴸᴸ
queue_length: 0
queue_cost: 0
budget: -60524
is_satisfied: ᴺᵁᴸᴸ
inflight_requests: ᴺᵁᴸᴸ
inflight_cost: ᴺᵁᴸᴸ
max_requests: ᴺᵁᴸᴸ
max_cost: ᴺᵁᴸᴸ
max_speed: ᴺᵁᴸᴸ
max_burst: ᴺᵁᴸᴸ
throttling_us: ᴺᵁᴸᴸ
tokens: ᴺᵁᴸᴸ
Columns:
resource
(String
) - Resource namepath
(String
) - Path to a scheduling node within this resource scheduling hierarchytype
(String
) - Type of a scheduling node.weight
(Float64
) - Weight of a node, used by a parent node of `fair`` type.priority
(Int64
) - Priority of a node, used by a parent node of 'priority' type (Lower value means higher priority).is_active
(UInt8
) - Whether this node is currently active - has resource requests to be dequeued and constraints satisfied.active_children
(UInt64
) - The number of children in active state.dequeued_requests
(UInt64
) - The total number of resource requests dequeued from this node.canceled_requests
(UInt64
) - The total number of resource requests canceled from this node.dequeued_cost
(UInt64
) - The sum of costs (e.g. size in bytes) of all requests dequeued from this node.canceled_cost
(UInt64
) - The sum of costs (e.g. size in bytes) of all requests canceled from this node.busy_periods
(UInt64
) - The total number of deactivations of this node.vruntime
(Nullable(Float64)
) - For children offair
nodes only. Virtual runtime of a node used by SFQ algorithm to select the next child to process in a max-min fair manner.system_vruntime
(Nullable(Float64)
) - Forfair
nodes only. Virtual runtime showingvruntime
of the last processed resource request. Used during child activation as the new value ofvruntime
.queue_length
(Nullable(UInt64)
) - Forfifo
nodes only. Current number of resource requests residing in the queue.queue_cost
(Nullable(UInt64)
) - Forfifo
nodes only. Sum of costs (e.g. size in bytes) of all requests residing in the queue.budget
(Nullable(Int64)
) - Forfifo
nodes only. The number of available "cost units" for new resource requests. Can appear in case of discrepancy of estimated and real costs of resource requests (e.g. after read/write failure)is_satisfied
(Nullable(UInt8)
) - For constraint nodes only (e.g.inflight_limit
). Equals1
if all the constraint of this node are satisfied.inflight_requests
(Nullable(Int64)
) - Forinflight_limit
nodes only. The number of resource requests dequeued from this node, that are currently in consumption state.inflight_cost
(Nullable(Int64)
) - Forinflight_limit
nodes only. The sum of costs (e.g. bytes) of all resource requests dequeued from this node, that are currently in consumption state.max_requests
(Nullable(Int64)
) - Forinflight_limit
nodes only. Upper limit forinflight_requests
leading to constraint violation.max_cost
(Nullable(Int64)
) - Forinflight_limit
nodes only. Upper limit forinflight_cost
leading to constraint violation.max_speed
(Nullable(Float64)
) - Forbandwidth_limit
nodes only. Upper limit for bandwidth in tokens per second.max_burst
(Nullable(Float64)
) - Forbandwidth_limit
nodes only. Upper limit fortokens
available in token-bucket throttler.throttling_us
(Nullable(Int64)
) - Forbandwidth_limit
nodes only. Total number of microseconds this node was in throttling state.tokens
(Nullable(Float64)
) - Forbandwidth_limit
nodes only. Number of tokens currently available in token-bucket throttler.