this feature through ShellCommandExecutor in
LinuxTaskController#createLogDir. However, I found the default
LinuxTaskController#createLogDir only has two input parameters
(TaskAttemptID taskID,boolean isCleanup), and does not satisfy the input
parameters of function initialize_task(const char* user,const
Hi Folks,
I need to find the task ID of the map task.
Please send me any ideas or suggestions.
Thanks,
Bharati
Sent from my iPad
Fortigate Filtered
Hi Bharati,
Your mapper class implementation methods have access to a MapContext:
http://hadoop.apache.org/docs/current/api/org/apache/hadoop/mapreduce/MapContext.html
This is a subclass of TaskAttemptContext:
after every map or after
all the maps?
Am I doing something wrong?
Thanks
Ankit
--
View this message in context:
http://old.nabble.com/Pass-the-TaskId-from-map-to-Reduce-tp27575531p27634001.html
Sent from the Hadoop core-user mailing list archive at Nabble.com.
() as the task id would have changed
Ankit
--
View this message in context:
http://old.nabble.com/Pass-the-TaskId-from-map-to-Reduce-tp27575531p27633914.html
Sent from the Hadoop core-user mailing list archive at Nabble.com.
when is closed function called after every map or after
all the maps?
Am I doing something wrong?
Thanks
Ankit
--
View this message in context:
http://old.nabble.com/Pass-the-TaskId-from-map-to-Reduce-tp27575531p27634001.html
Sent from the Hadoop core-user mailing list archive at Nabble.com.
of reduce.
I could give a task id as name of the file but dont know how will I read the
same file in configure() as the task id would have changed
Ankit
--
View this message in context:
http://old.nabble.com/Pass-the-TaskId-from-map-to-Reduce-tp27575531p27575531.html
Sent from the Hadoop core-user
read the
same file in configure() as the task id would have changed
Ankit
--
View this message in context:
http://old.nabble.com/Pass-the-TaskId-from-map-to-Reduce-tp27575531p27575531.html
Sent from the Hadoop core-user mailing list archive at Nabble.com.