public interface FailoverStrategy
|Modifier and Type||Interface and Description|
The factory to instantiate
|Modifier and Type||Method and Description|
Returns a set of IDs corresponding to the set of vertices that should be restarted.
Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)
executionVertexId- ID of the failed task
cause- cause of the failure
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.