public class TaskManagerServices extends Object
TaskExecutor
services such as the MemoryManager
, IOManager
,
ShuffleEnvironment
. All services are exclusive to a single TaskExecutor
.
Consequently, the respective TaskExecutor
is responsible for closing them.Modifier and Type | Field and Description |
---|---|
static String |
LOCAL_STATE_SUB_DIRECTORY_ROOT |
Modifier and Type | Method and Description |
---|---|
static TaskManagerServices |
fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration,
PermanentBlobService permanentBlobService,
MetricGroup taskManagerMetricGroup,
ExecutorService ioExecutor,
FatalErrorHandler fatalErrorHandler)
Creates and returns the task manager services.
|
BroadcastVariableManager |
getBroadcastVariableManager() |
Executor |
getIOExecutor() |
IOManager |
getIOManager() |
JobLeaderService |
getJobLeaderService() |
JobTable |
getJobTable() |
KvStateService |
getKvStateService() |
LibraryCacheManager |
getLibraryCacheManager() |
long |
getManagedMemorySize() |
ShuffleEnvironment<?,?> |
getShuffleEnvironment() |
TaskEventDispatcher |
getTaskEventDispatcher() |
TaskExecutorLocalStateStoresManager |
getTaskManagerStateStore() |
TaskSlotTable<Task> |
getTaskSlotTable() |
UnresolvedTaskManagerLocation |
getUnresolvedTaskManagerLocation() |
void |
shutDown()
Shuts the
TaskExecutor services down. |
@VisibleForTesting public static final String LOCAL_STATE_SUB_DIRECTORY_ROOT
public long getManagedMemorySize()
public IOManager getIOManager()
public ShuffleEnvironment<?,?> getShuffleEnvironment()
public KvStateService getKvStateService()
public UnresolvedTaskManagerLocation getUnresolvedTaskManagerLocation()
public BroadcastVariableManager getBroadcastVariableManager()
public TaskSlotTable<Task> getTaskSlotTable()
public JobTable getJobTable()
public JobLeaderService getJobLeaderService()
public TaskExecutorLocalStateStoresManager getTaskManagerStateStore()
public TaskEventDispatcher getTaskEventDispatcher()
public Executor getIOExecutor()
public LibraryCacheManager getLibraryCacheManager()
public void shutDown() throws FlinkException
TaskExecutor
services down.FlinkException
public static TaskManagerServices fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration, PermanentBlobService permanentBlobService, MetricGroup taskManagerMetricGroup, ExecutorService ioExecutor, FatalErrorHandler fatalErrorHandler) throws Exception
taskManagerServicesConfiguration
- task manager configurationpermanentBlobService
- permanentBlobService used by the servicestaskManagerMetricGroup
- metric group of the task managerioExecutor
- executor for async IO operationsfatalErrorHandler
- to handle class loading OOMsException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.