Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.restart |
Modifier and Type | Method and Description |
---|---|
RestartStrategy |
ExecutionGraph.getRestartStrategy() |
Modifier and Type | Method and Description |
---|---|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log)
Deprecated.
|
Constructor and Description |
---|
ExecutionGraph(JobInformation jobInformation,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
RestartStrategy restartStrategy,
FailoverStrategy.Factory failoverStrategyFactory,
SlotProvider slotProvider,
ClassLoader userClassLoader,
BlobWriter blobWriter,
Time allocationTimeout) |
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 |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
NoRestartStrategy.NoRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
NoOrFixedIfCheckpointingEnabledRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
FixedDelayRestartStrategy.FixedDelayRestartStrategyFactory.createRestartStrategy() |
static RestartStrategy |
RestartStrategyFactory.createRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
Creates a
RestartStrategy instance from the given RestartStrategies.RestartStrategyConfiguration . |
static RestartStrategy |
RestartStrategyResolving.resolve(RestartStrategies.RestartStrategyConfiguration clientConfiguration,
RestartStrategyFactory serverStrategyFactory,
boolean isCheckpointingEnabled)
Resolves which
RestartStrategy to use. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.