[MAPREDUCE-5335] Rename Job Tracker terminology in ShuffleSchedulerImpl

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.7.0
• Component/s: applicationmaster
• Target Version/s: 2.7.0
• Hadoop Flags: Reviewed
• Assignee: Devaraj Kavali
• Reporter: Devaraj Kavali
• Created: 20/Jun/13 10:40
• Updated: 10/Apr/15 20:19
• Resolved: 12/Feb/15 11:11

Description

2013-06-17 17:27:30,134 INFO [fetcher#2] org.apache.hadoop.mapreduce.task.reduce.ShuffleScheduler: Reporting fetch failure for attempt_1371467533091_0005_m_000010_0 to jobtracker.

ShuffleSchedulerImpl.java

  // Notify the JobTracker
  // after every read error, if 'reportReadErrorImmediately' is true or
  // after every 'maxFetchFailuresBeforeReporting' failures
  private void checkAndInformJobTracker(
      int failures, TaskAttemptID mapId, boolean readError,
      boolean connectExcpt) {
    if (connectExcpt || (reportReadErrorImmediately && readError)
        || ((failures % maxFetchFailuresBeforeReporting) == 0)) {
      LOG.info("Reporting fetch failure for " + mapId + " to jobtracker.");
      status.addFetchFailedMap((org.apache.hadoop.mapred.TaskAttemptID) mapId);
    }
  }