Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.restart | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
RestartStrategy |
ExecutionGraph.getRestartStrategy() |
Constructor and Description |
---|
ExecutionGraph(scala.concurrent.ExecutionContext executionContext,
JobID jobId,
String jobName,
Configuration jobConfig,
scala.concurrent.duration.FiniteDuration timeout,
RestartStrategy restartStrategy,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
ClassLoader userClassLoader) |
Modifier and Type | Class and Description |
---|---|
class |
FixedDelayRestartStrategy
Restart strategy which tries to restart the given
ExecutionGraph a fixed number of times
with a fixed time delay in between. |
class |
NoRestartStrategy
Restart strategy which does not restart an
ExecutionGraph . |
Modifier and Type | Method and Description |
---|---|
static RestartStrategy |
RestartStrategyFactory.createFromConfig(Configuration configuration)
Creates a
RestartStrategy instance from the given Configuration . |
static RestartStrategy |
RestartStrategyFactory.createRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
Creates a
RestartStrategy instance from the given RestartStrategies.RestartStrategyConfiguration . |
Modifier and Type | Method and Description |
---|---|
protected RestartStrategy |
JobManager.defaultRestartStrategy() |
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.