LocalJobRunner.Job

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,100 of 1,1000%52 of 520%52522282282626
run()2110%80%55505011
LocalJobRunner.Job(LocalJobRunner, JobID, String)2000%40%33404011
statusUpdate(TaskAttemptID, TaskStatus)1480%80%55313111
runTasks(List, ExecutorService, String)720%60%44161611
createOutputCommitter(boolean, JobID, Configuration)690%20%22141411
getCurrentCounters()640%100%669911
createMapExecutor()600%20%22131311
createReduceExecutor()520%20%22101011
initCounters(int, int)510%40%33111111
getMapTaskRunnables(JobSplit.TaskSplitMetaInfo[], JobID, Map)360%20%225511
getReduceTaskRunnables(JobID, Map)270%20%225511
fatalError(TaskAttemptID, String, boolean)190%n/a112211
done(TaskAttemptID)170%20%225511
reportNextRecordRange(TaskAttemptID, SortedRanges.Range)150%n/a112211
fsError(TaskAttemptID, String)150%n/a112211
shuffleError(TaskAttemptID, String)150%n/a112211
getProtocolSignature(String, long, int)60%n/a111111
commitPending(TaskAttemptID, TaskStatus)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