public class YarnTaskManager extends TaskManager
Constructor and Description |
---|
YarnTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Central handling of actor messages.
|
static void |
main(String[] args)
Entry point (main method) to run the TaskManager on YARN.
|
askTimeout, bcVarManager, config, connectionInfo, currentJobManager, fileCache, getAndCheckJobManagerAddress, getTaskManagerRemoteReference, handleError, handleJobManagerDisconnect, HEARTBEAT_INTERVAL, ioManager, isConnected, leaderRetrievalService, leaderSessionID, log, LOG, MAX_STARTUP_CONNECT_TIME, memoryManager, network, notifyLeaderAddress, numberOfSlots, parseArgsAndLoadConfig, parseTaskManagerConfiguration, postStop, preStart, resourceID, resources, runningTasks, runTaskManager, runTaskManager, RUNTIME_FAILURE_RETURN_CODE, selectNetworkInterfaceAndPort, selectNetworkInterfaceAndRunTaskManager, sendHeartbeatToJobManager, shutdown, startTaskManagerComponentsAndActor, STARTUP_CONNECT_LOG_SUPPRESS, STARTUP_FAILURE_RETURN_CODE, TASK_MANAGER_NAME, triggerTaskManagerRegistration, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, receive
receive
public YarnTaskManager(TaskManagerConfiguration config, ResourceID resourceID, InstanceConnectionInfo connectionInfo, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, LeaderRetrievalService leaderRetrievalService)
public static void main(String[] args)
args
- The command line arguments.public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
TaskManager
handleMessage
in interface FlinkActor
handleMessage
in class TaskManager
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.