public class FailoverRegion extends Object
Constructor and Description |
---|
FailoverRegion(ExecutionGraph executionGraph,
List<ExecutionVertex> connectedExecutions,
Map<JobVertexID,ExecutionJobVertex> tasks) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Void> |
createTerminationFutureOverAllConnectedVertexes() |
JobStatus |
getState() |
void |
onExecutionFail(Execution taskExecution,
Throwable cause) |
public FailoverRegion(ExecutionGraph executionGraph, List<ExecutionVertex> connectedExecutions, Map<JobVertexID,ExecutionJobVertex> tasks)
public JobStatus getState()
@VisibleForTesting protected CompletableFuture<Void> createTerminationFutureOverAllConnectedVertexes()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.