org.apache.flink.runtime.taskexecutor

Class TaskManagerServicesConfiguration

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration

public class TaskManagerServicesConfiguration
extends Object

Configuration for the task manager services such as the memory manager, the io manager and the metric registry.

Method Summary

Modifier and Type	Method and Description
static TaskManagerServicesConfiguration	fromConfiguration(Configuration configuration, ResourceID resourceID, String externalAddress, boolean localCommunicationOnly, TaskExecutorResourceSpec taskExecutorResourceSpec) Utility method to extract TaskManager config parameters from the configuration and to sanity check them.
String[]	getAlwaysParentFirstLoaderPatterns()
FlinkUserCodeClassLoaders.ResolveOrder	getClassLoaderResolveOrder()
Configuration	getConfiguration()
MemorySize	getManagedMemorySize()
MemorySize	getNetworkMemorySize()
int	getNumberOfSlots()
int	getNumIoThreads()
int	getPageSize()
ResourceID	getResourceID()
Optional<Time>	getSystemResourceMetricsProbingInterval()
TaskExecutorResourceSpec	getTaskExecutorResourceSpec()
String[]	getTmpDirPaths()

Methods inherited from class java.lang.Object

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

Method Detail

getConfiguration

public Configuration getConfiguration()

getResourceID

public ResourceID getResourceID()

getTmpDirPaths

public String[] getTmpDirPaths()

getNumberOfSlots

public int getNumberOfSlots()

getPageSize

public int getPageSize()

getTaskExecutorResourceSpec

public TaskExecutorResourceSpec getTaskExecutorResourceSpec()

getNetworkMemorySize

public MemorySize getNetworkMemorySize()

getManagedMemorySize

public MemorySize getManagedMemorySize()

getSystemResourceMetricsProbingInterval

public Optional<Time> getSystemResourceMetricsProbingInterval()

getClassLoaderResolveOrder

public FlinkUserCodeClassLoaders.ResolveOrder getClassLoaderResolveOrder()

getAlwaysParentFirstLoaderPatterns

public String[] getAlwaysParentFirstLoaderPatterns()

getNumIoThreads

public int getNumIoThreads()

fromConfiguration

public static TaskManagerServicesConfiguration fromConfiguration(Configuration configuration,
                                                                 ResourceID resourceID,
                                                                 String externalAddress,
                                                                 boolean localCommunicationOnly,
                                                                 TaskExecutorResourceSpec taskExecutorResourceSpec)
                                                          throws Exception

Utility method to extract TaskManager config parameters from the configuration and to sanity check them.

Parameters:

configuration - The configuration.

resourceID - resource ID of the task manager

externalAddress - identifying the IP address under which the TaskManager will be accessible

localCommunicationOnly - True if only local communication is possible. Use only in cases where only one task manager runs.

Returns:

configuration of task manager services used to create them

Throws:

Exception