Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adaptive | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
void |
StateTransitions.ToCancelling.goToCanceling(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Canceling state. |
void |
AdaptiveScheduler.goToCanceling(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToExecuting.goToExecuting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Executing state. |
void |
AdaptiveScheduler.goToExecuting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToFailing.goToFailing(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
Throwable failureCause,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Failing state. |
void |
AdaptiveScheduler.goToFailing(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
Throwable failureCause,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToRestarting.goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Restarting state. |
void |
AdaptiveScheduler.goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime,
List<ExceptionHistoryEntry> failureCollection) |
CompletableFuture<String> |
StateTransitions.ToStopWithSavepoint.goToStopWithSavepoint(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
CheckpointScheduling checkpointScheduling,
CompletableFuture<String> savepointFuture,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
StopWithSavepoint state. |
CompletableFuture<String> |
AdaptiveScheduler.goToStopWithSavepoint(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
CheckpointScheduling checkpointScheduling,
CompletableFuture<String> savepointFuture,
List<ExceptionHistoryEntry> failureCollection) |
Modifier and Type | Class and Description |
---|---|
class |
RootExceptionHistoryEntry
RootExceptionHistoryEntry extending ExceptionHistoryEntry by providing a list of
ExceptionHistoryEntry instances to store concurrently caught failures. |
Modifier and Type | Method and Description |
---|---|
static ExceptionHistoryEntry |
ExceptionHistoryEntry.create(AccessExecution failedExecution,
String taskName)
Creates an
ExceptionHistoryEntry based on the provided Execution . |
static ExceptionHistoryEntry |
ExceptionHistoryEntry.createGlobal(Throwable cause)
Creates an
ExceptionHistoryEntry that is not based on an Execution . |
Modifier and Type | Method and Description |
---|---|
Iterable<ExceptionHistoryEntry> |
RootExceptionHistoryEntry.getConcurrentExceptions() |
Modifier and Type | Method and Description |
---|---|
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromExceptionHistoryEntry(ExceptionHistoryEntry entry,
Iterable<ExceptionHistoryEntry> entries) |
Modifier and Type | Method and Description |
---|---|
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromExceptionHistoryEntry(ExceptionHistoryEntry entry,
Iterable<ExceptionHistoryEntry> entries) |
Constructor and Description |
---|
RootExceptionHistoryEntry(Throwable cause,
long timestamp,
String failingTaskName,
TaskManagerLocation taskManagerLocation,
Iterable<ExceptionHistoryEntry> concurrentExceptions)
Instantiates a
RootExceptionHistoryEntry . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.