<%@ page contentType="text/html; charset=UTF-8" import="javax.servlet.http.*" import="java.io.*" import="java.util.*" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.util.*" import="java.text.SimpleDateFormat" import="org.apache.hadoop.mapred.JobHistory.*" %> "/> "/> <%! private static SimpleDateFormat dateFormat = new SimpleDateFormat("d/MM HH:mm:ss") ; %> <% String jobid = request.getParameter("jobid"); String jobTrackerId = request.getParameter("jobTrackerId"); String taskid = request.getParameter("taskid"); JobHistory.JobInfo job = (JobHistory.JobInfo)request.getSession().getAttribute("job"); JobHistory.Task task = job.getAllTasks().get(taskid); %>

<%=taskid %> attempts for <%=jobid %>

<% if( Values.REDUCE.name().equals(task.get(Keys.TASK_TYPE) ) ){ %> <% } %> <% for( JobHistory.TaskAttempt attempt : task.getTaskAttempts().values() ) { printTaskAttempt(attempt, task.get(Keys.TASK_TYPE), out); } %>
Task IdStart TimeShuffle FinishedSort FinishedFinish TimeHostError
<%! private void printTaskAttempt(JobHistory.TaskAttempt taskAttempt, String type, JspWriter out) throws IOException{ out.print(""); out.print("" + taskAttempt.get(Keys.TASK_ATTEMPT_ID) + ""); out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, taskAttempt.getLong(Keys.START_TIME), 0 ) + "") ; if(Values.REDUCE.name().equals(type) ){ JobHistory.ReduceAttempt reduceAttempt = (JobHistory.ReduceAttempt)taskAttempt ; out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, reduceAttempt.getLong(Keys.SHUFFLE_FINISHED), reduceAttempt.getLong(Keys.START_TIME)) + "") ; out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, reduceAttempt.getLong(Keys.SORT_FINISHED), reduceAttempt.getLong(Keys.SHUFFLE_FINISHED)) + "") ; } out.print(""+ StringUtils.getFormattedTimeWithDiff(dateFormat, taskAttempt.getLong(Keys.FINISH_TIME), taskAttempt.getLong(Keys.START_TIME) ) + "") ; out.print("" + taskAttempt.get(Keys.HOSTNAME) + ""); out.print("" + taskAttempt.get(Keys.ERROR) + ""); out.print(""); } %>