<%@ 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 logFile = request.getParameter("logFile"); String encodedLogFileName = JobHistory.JobInfo.encodeJobHistoryFilePath(logFile); String taskStatus = request.getParameter("status"); String taskType = request.getParameter("taskType"); JobHistory.JobInfo job = (JobHistory.JobInfo)request. getSession().getAttribute("job"); Map tasks = job.getAllTasks(); %>

<%=taskStatus%> <%=taskType %> task list for <%=jobid %>

<% for (JobHistory.Task task : tasks.values()) { if (taskType.equals(task.get(Keys.TASK_TYPE))){ Map taskAttempts = task.getTaskAttempts(); for (JobHistory.TaskAttempt taskAttempt : taskAttempts.values()) { if (taskStatus.equals(taskAttempt.get(Keys.TASK_STATUS)) || taskStatus.equals("all")){ printTask(jobid, encodedLogFileName, taskAttempt, out); } } } } %>

Task Id

Start Time

Finish Time

Error

<%! private void printTask(String jobid, String logFile, JobHistory.TaskAttempt attempt, JspWriter out) throws IOException{ out.print(""); out.print("" + "" + attempt.get(Keys.TASKID) + ""); out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, attempt.getLong(Keys.START_TIME), 0 ) + ""); out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, attempt.getLong(Keys.FINISH_TIME), attempt.getLong(Keys.START_TIME) ) + ""); out.print("" + attempt.get(Keys.ERROR) + ""); out.print(""); } %>