public class YarnJobManager extends ContaineredJobManager
JobManager
with additional messages
to start/administer/stop the Yarn session.
param: flinkConfiguration Configuration object for the actor
param: futureExecutor Execution context which is used to execute concurrent tasks in the
ExecutionGraph
param: ioExecutor for blocking io operations
param: instanceManager Instance manager to manage the registered
TaskManager
param: scheduler Scheduler to schedule Flink jobs
param: libraryCacheManager Manager to manage uploaded jar files
param: archive Archive for finished Flink jobs
param: restartStrategyFactory Restart strategy to be used in case of a job recovery
param: timeout Timeout for futures
param: leaderElectionService LeaderElectionService to participate in the leader election
Constructor and Description |
---|
YarnJobManager(Configuration flinkConfiguration,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
InstanceManager instanceManager,
Scheduler scheduler,
BlobLibraryCacheManager libraryCacheManager,
akka.actor.ActorRef archive,
RestartStrategyFactory restartStrategyFactory,
scala.concurrent.duration.FiniteDuration timeout,
LeaderElectionService leaderElectionService,
SubmittedJobGraphStore submittedJobGraphs,
CheckpointRecoveryFactory checkpointRecoveryFactory,
scala.concurrent.duration.FiniteDuration jobRecoveryTimeout,
scala.Option<MetricRegistry> metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.duration.FiniteDuration |
DEFAULT_YARN_HEARTBEAT_DELAY() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Central work method of the JobManager actor.
|
scala.concurrent.duration.FiniteDuration |
jobPollingInterval() |
scala.concurrent.duration.FiniteDuration |
YARN_HEARTBEAT_DELAY() |
scala.Option<String> |
yarnFilesPath() |
handleContainerMessage, stopWhenJobFinished
archive, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, checkpointRecoveryFactory, context, createJobManagerComponents, currentJobs, currentResourceManager, currentResourceManagerConnectionId, decorateMessage, defaultSavepointDir, flinkConfiguration, futureExecutor, futuresToComplete, getAddress, getArchiveProps, getJobManagerProps, grantLeadership, haMode, handleError, instanceManager, ioExecutor, jobManagerMetricGroup, jobRecoveryTimeout, leaderElectionService, leaderSessionID, libraryCacheManager, log, LOG, main, metricsRegistry, onAddedJobGraph, onRemovedJobGraph, parseArgs, postRestart, postStop, preRestart, preStart, receive, restartStrategyFactory, retryOnBindException, revokeLeadership, runJobManager, runJobManager, RUNTIME_FAILURE_RETURN_CODE, scheduler, self, sender, shutdown, startActorSystem, startJobManagerActors, startJobManagerActors, startJobManagerActors, STARTUP_FAILURE_RETURN_CODE, submittedJobGraphs, supervisorStrategy, taskManagerMap, timeout, triggerResourceManagerReconnectInterval, unhandled, webMonitorPort
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, handleNoLeaderId, receive
receive
public YarnJobManager(Configuration flinkConfiguration, ScheduledExecutorService futureExecutor, Executor ioExecutor, InstanceManager instanceManager, Scheduler scheduler, BlobLibraryCacheManager libraryCacheManager, akka.actor.ActorRef archive, RestartStrategyFactory restartStrategyFactory, scala.concurrent.duration.FiniteDuration timeout, LeaderElectionService leaderElectionService, SubmittedJobGraphStore submittedJobGraphs, CheckpointRecoveryFactory checkpointRecoveryFactory, scala.concurrent.duration.FiniteDuration jobRecoveryTimeout, scala.Option<MetricRegistry> metricsRegistry)
public scala.concurrent.duration.FiniteDuration DEFAULT_YARN_HEARTBEAT_DELAY()
public scala.concurrent.duration.FiniteDuration YARN_HEARTBEAT_DELAY()
public scala.Option<String> yarnFilesPath()
public scala.concurrent.duration.FiniteDuration jobPollingInterval()
jobPollingInterval
in class ContaineredJobManager
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
JobManager
handleMessage
in interface FlinkActor
handleMessage
in class ContaineredJobManager
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.