Package org.apache.flink.runtime.resourcemanager.slotmanager

Class SlotManagerConfiguration

java.lang.Object

org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerConfiguration

public class SlotManagerConfiguration
extends Object

Configuration for the SlotManager.

Constructor Summary

Constructors

Constructor

Description

SlotManagerConfiguration(org.apache.flink.api.common.time.Time taskManagerRequestTimeout, org.apache.flink.api.common.time.Time taskManagerTimeout, java.time.Duration requirementCheckDelay, java.time.Duration declareNeededResourceDelay, boolean waitResultConsumedBeforeRelease, SlotMatchingStrategy slotMatchingStrategy, boolean evenlySpreadOutSlots, WorkerResourceSpec defaultWorkerResourceSpec, int numSlotsPerWorker, int maxSlotNum, org.apache.flink.api.common.resources.CPUResource maxTotalCpu, org.apache.flink.configuration.MemorySize maxTotalMem, int redundantTaskManagerNum)

Method Summary

Modifier and Type	Method	Description
static SlotManagerConfiguration	fromConfiguration(org.apache.flink.configuration.Configuration configuration, WorkerResourceSpec defaultWorkerResourceSpec)
java.time.Duration	getDeclareNeededResourceDelay()
WorkerResourceSpec	getDefaultWorkerResourceSpec()
int	getMaxSlotNum()
org.apache.flink.api.common.resources.CPUResource	getMaxTotalCpu()
org.apache.flink.configuration.MemorySize	getMaxTotalMem()
int	getNumSlotsPerWorker()
int	getRedundantTaskManagerNum()
java.time.Duration	getRequirementCheckDelay()
SlotMatchingStrategy	getSlotMatchingStrategy()
org.apache.flink.api.common.time.Time	getTaskManagerRequestTimeout()
org.apache.flink.api.common.time.Time	getTaskManagerTimeout()
boolean	isEvenlySpreadOutSlots()
boolean	isWaitResultConsumedBeforeRelease()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SlotManagerConfiguration

public SlotManagerConfiguration(org.apache.flink.api.common.time.Time taskManagerRequestTimeout,
                                org.apache.flink.api.common.time.Time taskManagerTimeout,
                                java.time.Duration requirementCheckDelay,
                                java.time.Duration declareNeededResourceDelay,
                                boolean waitResultConsumedBeforeRelease,
                                SlotMatchingStrategy slotMatchingStrategy,
                                boolean evenlySpreadOutSlots,
                                WorkerResourceSpec defaultWorkerResourceSpec,
                                int numSlotsPerWorker,
                                int maxSlotNum,
                                org.apache.flink.api.common.resources.CPUResource maxTotalCpu,
                                org.apache.flink.configuration.MemorySize maxTotalMem,
                                int redundantTaskManagerNum)

Method Detail

getTaskManagerRequestTimeout

public org.apache.flink.api.common.time.Time getTaskManagerRequestTimeout()

getTaskManagerTimeout

public org.apache.flink.api.common.time.Time getTaskManagerTimeout()

getRequirementCheckDelay

public java.time.Duration getRequirementCheckDelay()

getDeclareNeededResourceDelay

public java.time.Duration getDeclareNeededResourceDelay()

isWaitResultConsumedBeforeRelease

public boolean isWaitResultConsumedBeforeRelease()

getSlotMatchingStrategy

public SlotMatchingStrategy getSlotMatchingStrategy()

isEvenlySpreadOutSlots

public boolean isEvenlySpreadOutSlots()

getDefaultWorkerResourceSpec

public WorkerResourceSpec getDefaultWorkerResourceSpec()

getNumSlotsPerWorker

public int getNumSlotsPerWorker()

getMaxSlotNum

public int getMaxSlotNum()

getMaxTotalCpu

public org.apache.flink.api.common.resources.CPUResource getMaxTotalCpu()

getMaxTotalMem

public org.apache.flink.configuration.MemorySize getMaxTotalMem()

getRedundantTaskManagerNum

public int getRedundantTaskManagerNum()

fromConfiguration

public static SlotManagerConfiguration fromConfiguration(org.apache.flink.configuration.Configuration configuration,
                                                         WorkerResourceSpec defaultWorkerResourceSpec)
                                                  throws org.apache.flink.util.ConfigurationException

Throws:

org.apache.flink.util.ConfigurationException