%@ 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") ; %> <% 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; JobTracker tracker = JobTracker.getTracker(); String trackerLabel = StringUtils.simpleHostname(tracker.getJobTrackerMachine()); 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; } %>
Task | Complete | Status | " + "Start Time | Finish Time | Errors | Counters |
" + report.getTaskId() + " | "); out.print("" + StringUtils.formatPercent(report.getProgress(),2) + " | "); out.print("" + report.getState() + " | ");
out.println("" + StringUtils.getFormattedTimeWithDiff(dateFormat, report.getStartTime(),0) + " | ");
out.println("" + StringUtils.getFormattedTimeWithDiff(dateFormat,
report.getFinishTime(), report.getStartTime()) + " | ");
String[] diagnostics = report.getDiagnostics();
out.print(""); for (int j = 0; j < diagnostics.length ; j++) { out.println(diagnostics[j]); } out.println(" | ");
out.println("" + "" + report.getCounters().size() + " |