Searched defs:mapTaskId (Results 1 – 10 of 10) sorted by relevance
99 public void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
108 public void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
367 public abstract void addFetchFailedMap(TaskAttemptID mapTaskId); in addFetchFailedMap()
117 private boolean copyMapOutput(TaskAttemptID mapTaskId) throws IOException { in copyMapOutput()
451 TaskID mapTaskId = mapId.getTaskID(); in merge() local
96 void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
294 synchronized void addFetchFailedMap(TaskAttemptID mapTaskId) {} in addFetchFailedMap()
2243 TaskAttemptID mapTaskId = cr.getLocation().getTaskAttemptId(); in fetchOutputs() local
3424 TaskAttemptID mapTaskId, in fetchFailureNotification()
633 TaskID mapTaskId = new TaskID(job.getID(), true, 0); in validateTaskLevelKeyValues() local