Class TaskAttemptTooManyFetchFailureEvent

java.lang.Object
org.apache.hadoop.yarn.event.AbstractEvent<TaskAttemptEventType>
org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEvent
org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptTooManyFetchFailureEvent
All Implemented Interfaces:
org.apache.hadoop.yarn.event.Event<TaskAttemptEventType>

public class TaskAttemptTooManyFetchFailureEvent extends TaskAttemptEvent
TaskAttemptTooManyFetchFailureEvent is used for TA_TOO_MANY_FETCH_FAILURE.
  • Constructor Details

    • TaskAttemptTooManyFetchFailureEvent

      public TaskAttemptTooManyFetchFailureEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptId, org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId reduceId, String reduceHost)
      Create a new TaskAttemptTooManyFetchFailureEvent.
      Parameters:
      attemptId - the id of the mapper task attempt
      reduceId - the id of the reporting reduce task attempt.
      reduceHost - the hostname of the reporting reduce task attempt.
  • Method Details

    • getReduceId

      public org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId getReduceId()
    • getReduceHost

      public String getReduceHost()