public final class YarnDriverRuntimeRestartManager extends Object implements DriverRuntimeRestartManager
Modifier and Type | Method and Description |
---|---|
RestartEvaluators |
getPreviousEvaluators()
Used by
DriverRestartManager . |
int |
getResubmissionAttempts()
Determines the number of times the Driver has been submitted based on the container ID environment
variable provided by YARN.
|
void |
informAboutEvaluatorFailures(Set<String> evaluatorIds)
Calls the appropriate handler via REEFEventHandlers, which is a runtime specific implementation
of the YARN runtime.
|
void |
recordAllocatedEvaluator(String id)
Records the evaluators when it is allocated.
|
void |
recordRemovedEvaluator(String id)
Records a removed evaluator into the evaluator log.
|
public int getResubmissionAttempts()
getResubmissionAttempts
in interface DriverRuntimeRestartManager
public void recordAllocatedEvaluator(String id)
DriverRuntimeRestartManager
recordAllocatedEvaluator
in interface DriverRuntimeRestartManager
id
- The evaluator ID of the allocated evaluator.public void recordRemovedEvaluator(String id)
DriverRuntimeRestartManager
recordRemovedEvaluator
in interface DriverRuntimeRestartManager
id
- The evaluator ID of the removed evaluator.public RestartEvaluators getPreviousEvaluators()
DriverRestartManager
.
Gets the list of previous containers from the resource manager,
compares that list to the YarnDriverRuntimeRestartManager's own list based on the evalutor preserver,
and determine which evaluators are alive and which have failed during restart.getPreviousEvaluators
in interface DriverRuntimeRestartManager
EvaluatorRestartInfo
for evaluators that have either failed or survived
driver restart.public void informAboutEvaluatorFailures(Set<String> evaluatorIds)
informAboutEvaluatorFailures
in interface DriverRuntimeRestartManager
evaluatorIds
- the set of evaluator IDs of failed evaluators during restart.Copyright © 2017 The Apache Software Foundation. All rights reserved.