public class DefaultGiraphJobRetryChecker extends Object implements GiraphJobRetryChecker
GiraphJobRetryChecker
,
which never retries the job.Constructor and Description |
---|
DefaultGiraphJobRetryChecker() |
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
|
public boolean shouldRetry(org.apache.hadoop.mapreduce.Job submittedJob, int tryCount)
GiraphJobRetryChecker
shouldRetry
in interface GiraphJobRetryChecker
submittedJob
- Job that ran and failedtryCount
- How many times have we tried to run the job until nowpublic String shouldRestartCheckpoint(org.apache.hadoop.mapreduce.Job lastAttempt)
GiraphJobRetryChecker
shouldRestartCheckpoint
in interface GiraphJobRetryChecker
lastAttempt
- latest failed jobCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.