public interface GiraphJobRetryChecker
Modifier and Type | Method and Description |
---|---|
String |
shouldRestartCheckpoint(org.apache.hadoop.mapreduce.Job lastAttempt)
The job has been checkpointed and halted.
|
boolean |
shouldRetry(org.apache.hadoop.mapreduce.Job submittedJob,
int tryCount)
Check if the job should be retried
|
boolean shouldRetry(org.apache.hadoop.mapreduce.Job submittedJob, int tryCount)
submittedJob
- Job that ran and failedtryCount
- How many times have we tried to run the job until nowString shouldRestartCheckpoint(org.apache.hadoop.mapreduce.Job lastAttempt) throws IOException
lastAttempt
- latest failed jobIOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.