public void launchTask ( Task task , String trackerName , InetAddress addr ) { CoronaSessionInfo info = new CoronaSessionInfo ( coronaJT . getSessionId ( ) , coronaJT . getJobTrackerAddress ( ) , coronaJT . getSecondaryTrackerAddress ( ) ) ; LaunchTaskAction action = new LaunchTaskAction ( task , info ) ; String description = "LaunchTaskAction " + action . getTask ( ) . getTaskID ( ) ; ActionToSend actionToSend = new ActionToSend ( trackerName , addr , action , description ) ; LOG . info ( "Queueing " + description + " to worker " + trackerName + "(" + addr . host + ":" + addr . port + ")" ) ; allWorkQueues . enqueueAction ( actionToSend ) ; }
Enqueue a launch task action .