Lines Matching refs:TaskAttempt
38 import org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt;
86 Map<TaskAttemptId, TaskAttempt> attempts = in testKillJob()
90 Iterator<TaskAttempt> it = attempts.values().iterator(); in testKillJob()
128 Map<TaskAttemptId, TaskAttempt> attempts = task1.getAttempts(); in testKillTask()
131 Iterator<TaskAttempt> iter = attempts.values().iterator(); in testKillTask()
198 TaskAttempt mapAttempt = mapTask.getAttempts().values().iterator().next(); in testKillTaskWait()
200 TaskAttempt reduceAttempt = reduceTask.getAttempts().values().iterator().next(); in testKillTaskWait()
267 TaskAttempt mapAttempt = mapTask.getAttempts().values().iterator().next(); in testKillTaskWaitKillJobAfterTA_DONE()
269 TaskAttempt reduceAttempt = reduceTask.getAttempts().values().iterator().next(); in testKillTaskWaitKillJobAfterTA_DONE()
319 TaskAttempt attempt = task1.getAttempts().values().iterator().next(); in testKillTaskAttempt()
337 Map<TaskAttemptId, TaskAttempt> attempts = task1.getAttempts(); in testKillTaskAttempt()
340 Iterator<TaskAttempt> iter = attempts.values().iterator(); in testKillTaskAttempt()