Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.restart |
Modifier and Type | Method and Description |
---|---|
RestartStrategy |
ExecutionGraph.getRestartStrategy() |
Constructor and Description |
---|
ExecutionGraph(Executor futureExecutor,
Executor ioExecutor,
JobID jobId,
String jobName,
Configuration jobConfig,
SerializedValue<ExecutionConfig> serializedConfig,
scala.concurrent.duration.FiniteDuration timeout,
RestartStrategy restartStrategy,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
Scheduler scheduler,
ClassLoader userClassLoader,
MetricGroup metricGroup) |
Modifier and Type | Class and Description |
---|---|
class |
FailureRateRestartStrategy
Restart strategy which tries to restart the given
ExecutionGraph when failure rate exceeded
with a fixed time delay in between. |
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 |
---|---|
abstract RestartStrategy |
RestartStrategyFactory.createRestartStrategy()
Factory method to create a restart strategy
|
RestartStrategy |
NoRestartStrategy.NoRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
FixedDelayRestartStrategy.FixedDelayRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory.createRestartStrategy() |
static RestartStrategy |
RestartStrategyFactory.createRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
Creates a
RestartStrategy instance from the given RestartStrategies.RestartStrategyConfiguration . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.