} else {
LOG.warn("Job {} is failed twice, will not be submitted again.", jobName);
}
}
}
<BUG>double prog = calculateProgress(jc, jobClient) / totalNeededMRJobs;
</BUG>
notifyProgress(prog, lastProg);
lastProg = prog;
try {

} else {
LOG.warn("Job {} is failed twice, will not be submitted again.", jobName);
}
}
}
double prog = calculateProgress(finalSucessfulJobIDs, jc, jobClient) / totalNeededMRJobs;
notifyProgress(prog, lastProg);
lastProg = prog;
try {
