LocalJobRunner.Job

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total990 of 9900%52 of 520%52522282282626
run()1960%80%55505011
LocalJobRunner.Job(LocalJobRunner, JobID, String)1940%40%33404011
statusUpdate(TaskAttemptID, TaskStatus)1480%80%55313111
getCurrentCounters()640%100%669911
runTasks(List, ExecutorService, String)580%60%44161611
createOutputCommitter(boolean, JobID, Configuration)570%20%22141411
initCounters(int, int)510%40%33111111
createMapExecutor()480%20%22131311
createReduceExecutor()400%20%22101011
getMapTaskRunnables(JobSplit.TaskSplitMetaInfo[], JobID, Map)360%20%225511
getReduceTaskRunnables(JobID, Map)270%20%225511
done(TaskAttemptID)170%20%225511
fatalError(TaskAttemptID, String, boolean)70%n/a112211
getProtocolSignature(String, long, int)60%n/a111111
commitPending(TaskAttemptID, TaskStatus)60%n/a112211
reportNextRecordRange(TaskAttemptID, SortedRanges.Range)60%n/a112211
fsError(TaskAttemptID, String)60%n/a112211
shuffleError(TaskAttemptID, String)60%n/a112211
getMapCompletionEvents(JobID, int, int, TaskAttemptID)60%n/a111111
getProtocolVersion(String, long)20%n/a111111
getTask(JvmContext)20%n/a111111
canCommit(TaskAttemptID)20%n/a111111
getCheckpointID(TaskID)20%n/a111111
reportDiagnosticInfo(TaskAttemptID, String)0%n/a111111
preempted(TaskAttemptID, TaskStatus)0%n/a111111
setCheckpointID(TaskID, TaskCheckpointID)0%n/a111111