public void killTasks ( String trackerName , InetAddress addr , List < KillTaskAction > killActions ) { for ( KillTaskAction killAction : killActions ) { String description = "KillTaskAction " + killAction . getTaskID ( ) ; LOG . info ( "Queueing " + description + " to worker " + trackerName + "(" + addr . host + ":" + addr . port + ")" ) ; allWorkQueues . enqueueAction ( new ActionToSend ( trackerName , addr , killAction , description ) ) ; } }
Enqueue kill tasks actions .