@SuppressWarnings("deprecation")
  public void killJob(JobID jobId, Map<String, InetAddress> allTrackers) {
    for (Map.Entry<String, InetAddress> entry : allTrackers.entrySet()) {
      String trackerName = entry.getKey();
      InetAddress addr = entry.getValue();
      String description = "KillJobAction " + jobId;
      ActionToSend action = new ActionToSend(trackerName, addr,
          new KillJobAction(jobId), description);
      allWorkQueues.enqueueAction(action);
      LOG.info("Queueing "  + description + " to worker " +
        trackerName + "(" + addr.host + ":" + addr.port + ")");
    }
  }
@ SuppressWarnings ( "deprecation" ) public void killJob ( JobID jobId , Map < String , InetAddress > allTrackers ) { for ( Map . Entry < String , InetAddress > entry : allTrackers . entrySet ( ) ) { String trackerName = entry . getKey ( ) ; InetAddress addr = entry . getValue ( ) ; String description = "KillJobAction " + jobId ; ActionToSend action = new ActionToSend ( trackerName , addr , new KillJobAction ( jobId ) , description ) ; allWorkQueues . enqueueAction ( action ) ; LOG . info ( "Queueing " + description + " to worker " + trackerName + "(" + addr . host + ":" + addr . port + ")" ) ; } }
Enqueue an action to kill the job.
@param jobId The job identifier.
@param allTrackers All trackers to send the kill to.