public class YarnJobManager extends JobManager
JobManager
with additional messages
to start/administer/stop the Yarn session.
Modifier and Type | Class and Description |
---|---|
class |
YarnJobManager.AMRMClientAsyncHandler |
Constructor and Description |
---|
YarnJobManager(Configuration flinkConfiguration,
ExecutorService executorService,
InstanceManager instanceManager,
Scheduler scheduler,
BlobLibraryCacheManager libraryCacheManager,
akka.actor.ActorRef archive,
RestartStrategy restartStrategy,
scala.concurrent.duration.FiniteDuration timeout,
LeaderElectionService leaderElectionService,
SubmittedJobGraphStore submittedJobGraphs,
CheckpointRecoveryFactory checkpointRecoveryFactory,
SavepointStore savepointStore,
scala.concurrent.duration.FiniteDuration jobRecoveryTimeout) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.List<org.apache.hadoop.yarn.api.records.Container> |
allocatedContainersList() |
org.apache.flink.yarn.YarnJobManager.AMRMClientAsyncHandler$ |
AMRMClientAsyncHandler() |
scala.Option<org.apache.hadoop.yarn.api.records.ContainerLaunchContext> |
containerLaunchContext() |
scala.concurrent.duration.FiniteDuration |
DEFAULT_YARN_HEARTBEAT_DELAY() |
Boolean |
detached() |
int |
failedContainers() |
scala.concurrent.duration.FiniteDuration |
FAST_YARN_HEARTBEAT_DELAY() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Central work method of the JobManager actor.
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleYarnMessage() |
int |
maxFailedContainers() |
int |
memoryPerTaskManager() |
scala.Option<akka.actor.ActorRef> |
messageListener() |
scala.Option<org.apache.hadoop.yarn.client.api.NMClient> |
nmClientOption() |
int |
numPendingRequests() |
int |
numTaskManagers() |
scala.Option<org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest>> |
rmClientOption() |
int |
runningContainers() |
scala.collection.immutable.List<org.apache.hadoop.yarn.api.records.Container> |
runningContainersList() |
JobID |
stopWhenJobFinished() |
Object |
taskManagerRunnerClass() |
scala.concurrent.duration.FiniteDuration |
YARN_HEARTBEAT_DELAY() |
ARCHIVE_NAME, archive, checkpointRecoveryFactory, createJobManagerComponents, currentJobs, defaultRestartStrategy, executionContext, executorService, flinkConfiguration, futuresToComplete, getAddress, getJobManagerActorRef, getJobManagerActorRef, getJobManagerActorRef, getJobManagerActorRefFuture, getJobManagerAkkaURL, getLocalJobManagerAkkaURL, getRemoteJobManagerAkkaURL, getRemoteJobManagerAkkaURL, grantLeadership, handleError, instanceManager, JOB_MANAGER_NAME, jobRecoveryTimeout, leaderElectionService, leaderSessionID, libraryCacheManager, log, LOG, main, onAddedJobGraph, onRemovedJobGraph, parseArgs, postStop, preStart, recoveryMode, retryOnBindException, revokeLeadership, runJobManager, runJobManager, RUNTIME_FAILURE_RETURN_CODE, savepointStore, scheduler, startActor, startActorSystemAndJobManagerActors, startJobManagerActors, startJobManagerActors, STARTUP_FAILURE_RETURN_CODE, submittedJobGraphs, timeout, unhandled, webMonitorPort
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, receive
receive
public YarnJobManager(Configuration flinkConfiguration, ExecutorService executorService, InstanceManager instanceManager, Scheduler scheduler, BlobLibraryCacheManager libraryCacheManager, akka.actor.ActorRef archive, RestartStrategy restartStrategy, scala.concurrent.duration.FiniteDuration timeout, LeaderElectionService leaderElectionService, SubmittedJobGraphStore submittedJobGraphs, CheckpointRecoveryFactory checkpointRecoveryFactory, SavepointStore savepointStore, scala.concurrent.duration.FiniteDuration jobRecoveryTimeout)
public scala.concurrent.duration.FiniteDuration FAST_YARN_HEARTBEAT_DELAY()
public scala.concurrent.duration.FiniteDuration DEFAULT_YARN_HEARTBEAT_DELAY()
public scala.concurrent.duration.FiniteDuration YARN_HEARTBEAT_DELAY()
public Object taskManagerRunnerClass()
public Boolean detached()
public JobID stopWhenJobFinished()
public scala.Option<org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest>> rmClientOption()
public scala.Option<org.apache.hadoop.yarn.client.api.NMClient> nmClientOption()
public scala.Option<akka.actor.ActorRef> messageListener()
public scala.Option<org.apache.hadoop.yarn.api.records.ContainerLaunchContext> containerLaunchContext()
public int runningContainers()
public int failedContainers()
public int numTaskManagers()
public int maxFailedContainers()
public int numPendingRequests()
public int memoryPerTaskManager()
public scala.collection.immutable.List<org.apache.hadoop.yarn.api.records.Container> allocatedContainersList()
public scala.collection.immutable.List<org.apache.hadoop.yarn.api.records.Container> runningContainersList()
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
JobManager
handleMessage
in interface FlinkActor
handleMessage
in class JobManager
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleYarnMessage()
public org.apache.flink.yarn.YarnJobManager.AMRMClientAsyncHandler$ AMRMClientAsyncHandler()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.