public void commitTask ( String trackerName , InetAddress addr , CommitTaskAction action ) { String description = "KillTaskAction " + action . getTaskID ( ) ; LOG . info ( "Queueing " + description + " to worker " + trackerName + "(" + addr . host + ":" + addr . port + ")" ) ; allWorkQueues . enqueueAction ( new ActionToSend ( trackerName , addr , action , description ) ) ; }
Enqueue a commit task action .