public class MesosJobManager extends ContaineredJobManager
Constructor and Description |
---|
MesosJobManager(Configuration flinkConfiguration,
Executor 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 |
jobPollingInterval() |
handleContainerMessage, handleMessage, stopWhenJobFinished
ARCHIVE_NAME, archive, checkpointRecoveryFactory, createJobManagerComponents, currentJobs, currentResourceManager, defaultSavepointDir, flinkConfiguration, futureExecutor, futuresToComplete, getAddress, getArchiveProps, getJobManagerActorRef, getJobManagerActorRef, getJobManagerActorRef, getJobManagerAkkaURL, getJobManagerProps, getLocalJobManagerAkkaURL, getRemoteJobManagerAkkaURL, getRemoteJobManagerAkkaURL, grantLeadership, haMode, handleError, instanceManager, ioExecutor, JOB_MANAGER_NAME, jobManagerMetricGroup, jobRecoveryTimeout, leaderElectionService, leaderSessionID, libraryCacheManager, log, LOG, main, metricsRegistry, onAddedJobGraph, onRemovedJobGraph, parseArgs, postStop, preStart, restartStrategyFactory, retryOnBindException, revokeLeadership, runJobManager, runJobManager, RUNTIME_FAILURE_RETURN_CODE, scheduler, shutdown, startActorSystemAndJobManagerActors, startJobManagerActors, startJobManagerActors, STARTUP_FAILURE_RETURN_CODE, submittedJobGraphs, taskManagerMap, timeout, unhandled, webMonitorPort
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, receive
receive
public MesosJobManager(Configuration flinkConfiguration, Executor 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 jobPollingInterval()
jobPollingInterval
in class ContaineredJobManager
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.