Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
Scheduler |
ExecutionGraph.getScheduler() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.scheduleAll(Scheduler scheduler,
boolean queued) |
void |
ExecutionGraph.scheduleForExecution(Scheduler scheduler) |
boolean |
ExecutionVertex.scheduleForExecution(Scheduler scheduler,
boolean queued) |
boolean |
Execution.scheduleForExecution(Scheduler scheduler,
boolean queued)
NOTE: This method only throws exceptions if it is in an illegal state to be scheduled, or if the tasks needs
to be scheduled immediately and no resource is available.
|
Modifier and Type | Method and Description |
---|---|
protected Scheduler |
JobManager.scheduler() |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple12<ExecutorService,InstanceManager,Scheduler,BlobLibraryCacheManager,RestartStrategy,scala.concurrent.duration.FiniteDuration,Object,LeaderElectionService,SubmittedJobGraphStore,CheckpointRecoveryFactory,SavepointStore,scala.concurrent.duration.FiniteDuration> |
JobManager.createJobManagerComponents(Configuration configuration,
scala.Option<LeaderElectionService> leaderElectionServiceOption)
Create the job manager components as (instanceManager, scheduler, libraryCacheManager,
archiverProps, defaultExecutionRetries,
delayBetweenRetries, timeout)
|
scala.Tuple12<ExecutorService,InstanceManager,Scheduler,BlobLibraryCacheManager,RestartStrategy,scala.concurrent.duration.FiniteDuration,Object,LeaderElectionService,SubmittedJobGraphStore,CheckpointRecoveryFactory,SavepointStore,scala.concurrent.duration.FiniteDuration> |
JobManager$.createJobManagerComponents(Configuration configuration,
scala.Option<LeaderElectionService> leaderElectionServiceOption)
Create the job manager components as (instanceManager, scheduler, libraryCacheManager,
archiverProps, defaultExecutionRetries,
delayBetweenRetries, timeout)
|
Constructor and Description |
---|
JobManager(Configuration flinkConfiguration,
ExecutorService executorService,
InstanceManager instanceManager,
Scheduler scheduler,
BlobLibraryCacheManager libraryCacheManager,
akka.actor.ActorRef archive,
RestartStrategy defaultRestartStrategy,
scala.concurrent.duration.FiniteDuration timeout,
LeaderElectionService leaderElectionService,
SubmittedJobGraphStore submittedJobGraphs,
CheckpointRecoveryFactory checkpointRecoveryFactory,
SavepointStore savepointStore,
scala.concurrent.duration.FiniteDuration jobRecoveryTimeout) |
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) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.