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,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
FailoverStrategy.Factory failoverStrategyFactory,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp) |
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,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
long initializationTimestamp)
Builds the ExecutionGraph from the JobGraph.
|
Constructor and Description |
---|
ExecutionGraph(JobInformation jobInformation,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
RestartStrategy restartStrategy,
int maxPriorAttemptsHistoryLength,
FailoverStrategy.Factory failoverStrategyFactory,
SlotProvider slotProvider,
ClassLoader userClassLoader,
BlobWriter blobWriter,
Time allocationTimeout,
PartitionReleaseStrategy.Factory partitionReleaseStrategyFactory,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ScheduleMode scheduleMode,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp) |
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 . |
class |
ThrowingRestartStrategy
A restart strategy that validates that it is not in use by throwing
IllegalStateException
on any method call. |
Modifier and Type | Method and Description |
---|---|
RestartStrategy |
NoRestartStrategy.NoRestartStrategyFactory.createRestartStrategy() |
abstract RestartStrategy |
RestartStrategyFactory.createRestartStrategy()
Factory method to create a restart strategy.
|
RestartStrategy |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
ThrowingRestartStrategy.ThrowingRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
FixedDelayRestartStrategy.FixedDelayRestartStrategyFactory.createRestartStrategy() |
RestartStrategy |
NoOrFixedIfCheckpointingEnabledRestartStrategyFactory.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–2021 The Apache Software Foundation. All rights reserved.