import org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public void transition(TaskAttemptImpl taskAttempt, 
    TaskAttemptEvent event) {
  // Tell any speculator that we're requesting a container
  taskAttempt.eventHandler.handle
      (new SpeculatorEvent(taskAttempt.getID().getTaskId(), +1));
  //request for container
  if (rescheduled) {
    taskAttempt.eventHandler.handle(
        ContainerRequestEvent.createContainerRequestEventForFailedContainer(
            taskAttempt.attemptId, 
            taskAttempt.resourceCapability));
  } else {
    taskAttempt.eventHandler.handle(new ContainerRequestEvent(
        taskAttempt.attemptId, taskAttempt.resourceCapability,
        taskAttempt.dataLocalHosts.toArray(
            new String[taskAttempt.dataLocalHosts.size()]),
        taskAttempt.dataLocalRacks.toArray(
            new String[taskAttempt.dataLocalRacks.size()])));
  }
}
 

import org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public void transition(TaskAttemptImpl taskAttempt, 
    TaskAttemptEvent event) {
  // Tell any speculator that we're requesting a container
  taskAttempt.eventHandler.handle
      (new SpeculatorEvent(taskAttempt.getID().getTaskId(), +1));
  //request for container
  if (rescheduled) {
    taskAttempt.eventHandler.handle(
        ContainerRequestEvent.createContainerRequestEventForFailedContainer(
            taskAttempt.attemptId, 
            taskAttempt.resourceCapability));
  } else {
	
 
    taskAttempt.eventHandler.handle(new ContainerRequestEvent(
        taskAttempt.attemptId, taskAttempt.resourceCapability,true,true,true,
        taskAttempt.dataLocalHosts.toArray(
            new String[taskAttempt.dataLocalHosts.size()]),
        taskAttempt.dataLocalRacks.toArray(
            new String[taskAttempt.dataLocalRacks.size()])));
  }
}
 

import org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent; //导入依赖的package包/类
void addAttempt() {
  TaskAttempt taskAttempt
      = new MyTaskAttemptImpl(taskID, attempts.size(), clock);
  TaskAttemptId taskAttemptID = taskAttempt.getID();

  attempts.put(taskAttemptID, taskAttempt);

  System.out.println("TLTRE.MyTaskImpl.addAttempt " + getID());

  SpeculatorEvent event = new SpeculatorEvent(taskID, +1);
  dispatcher.getEventHandler().handle(event);
}
 

import org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent; //导入依赖的package包/类
void startUp() {
  startMockTime = clock.getTime();
  overridingState = null;

  slotsInUse.addAndGet(taskTypeSlots(myAttemptID.getTaskId().getTaskType()));

  System.out.println("TLTRE.MyTaskAttemptImpl.startUp starting " + getID());

  SpeculatorEvent event = new SpeculatorEvent(getID().getTaskId(), -1);
  dispatcher.getEventHandler().handle(event);
}