<%@ page contentType="text/html; charset=UTF-8" import="javax.servlet.*" import="javax.servlet.http.*" import="java.io.*" import="java.util.*" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.util.*" import="java.lang.Integer" import="java.text.SimpleDateFormat" %> <%! static SimpleDateFormat dateFormat = new SimpleDateFormat("d-MMM-yyyy HH:mm:ss") ; %> <% JobTracker tracker = (JobTracker) application.getAttribute("job.tracker"); String trackerName = StringUtils.simpleHostname(tracker.getJobTrackerMachine()); String jobid = request.getParameter("jobid"); String type = request.getParameter("type"); String pagenum = request.getParameter("pagenum"); int pnum = Integer.parseInt(pagenum); int next_page = pnum+1; int numperpage = 2000; JobInProgress job = (JobInProgress) tracker.getJob(jobid); JobProfile profile = (job != null) ? (job.getProfile()) : null; JobStatus status = (job != null) ? (job.getStatus()) : null; TaskReport[] reports = null; int start_index = (pnum - 1) * numperpage; int end_index = start_index + numperpage; int report_len = 0; if ("map".equals(type)){ reports = (job != null) ? tracker.getMapTaskReports(jobid) : null; } else{ reports = (job != null) ? tracker.getReduceTaskReports(jobid) : null; } %> <%@page import="org.apache.hadoop.dfs.JspHelper"%> Hadoop <%=type%> task list for <%=jobid%> on <%=trackerName%>

Hadoop <%=type%> task list for <%=jobid%> on <%=trackerName%>

<% if (job == null) { out.print("Job " + jobid + " not found.
\n"); return; } report_len = reports.length; if (report_len <= start_index) { out.print("No such tasks"); } else { out.print("
"); out.print("

Tasks

"); out.print("
"); out.print(""); out.print("" + ""); if (end_index > report_len){ end_index = report_len; } for (int i = start_index ; i < end_index; i++) { TaskReport report = reports[i]; out.print(""); out.print(""); out.print(""); out.println(""); out.println(""); String[] diagnostics = report.getDiagnostics(); out.print(""); out.println(""); } out.print("
TaskCompleteStatusStart TimeFinish TimeErrorsCounters
" + report.getTaskId() + "" + StringUtils.formatPercent(report.getProgress(),2) + JspHelper.percentageGraph(report.getProgress() * 100f, 80) + "" + report.getState() + "
" + StringUtils.getFormattedTimeWithDiff(dateFormat, report.getStartTime(),0) + "
" + StringUtils.getFormattedTimeWithDiff(dateFormat, report.getFinishTime(), report.getStartTime()) + "
");
         for (int j = 0; j < diagnostics.length ; j++) {
             out.println(diagnostics[j]);
         }
         out.println("

" + "" + report.getCounters().size() + "
"); out.print("
"); } if (end_index < report_len) { out.print("
" + "" + "Next" + "
"); } if (start_index != 0) { out.print("
" + "" + "Prev" + "
"); } %>
Go back to JobTracker
Hadoop, 2007.