public class YarnTaskManager extends TaskManager
Constructor and Description |
---|
YarnTaskManager(TaskManagerConfiguration config,
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.
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleYarnMessages() |
askTimeout, bcVarManager, config, connectionInfo, currentJobManager, DELAY_AFTER_REFUSED_REGISTRATION, fileCache, getAndCheckJobManagerAddress, getTaskManagerRemoteReference, handleError, handleJobManagerDisconnect, HEARTBEAT_INTERVAL, INITIAL_REGISTRATION_TIMEOUT, ioManager, isConnected, leaderRetrievalService, leaderSessionID, log, LOG, main, MAX_REGISTRATION_TIMEOUT, MAX_STARTUP_CONNECT_TIME, memoryManager, network, notifyLeaderAddress, numberOfSlots, parseArgsAndLoadConfig, parseTaskManagerConfiguration, postStop, preStart, resources, runningTasks, runTaskManager, runTaskManager, RUNTIME_FAILURE_RETURN_CODE, selectNetworkInterfaceAndPort, selectNetworkInterfaceAndRunTaskManager, sendHeartbeatToJobManager, 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, InstanceConnectionInfo connectionInfo, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, LeaderRetrievalService leaderRetrievalService)
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
TaskManager
handleMessage
in interface FlinkActor
handleMessage
in class TaskManager
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleYarnMessages()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.