package org.apache.hadoop.mapred; import javax.servlet.*; import javax.servlet.http.*; import javax.servlet.jsp.*; 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; public final class jobtasks_jsp extends org.apache.jasper.runtime.HttpJspBase implements org.apache.jasper.runtime.JspSourceDependent { static SimpleDateFormat dateFormat = new SimpleDateFormat("d-MMM-yyyy HH:mm:ss") ; private static java.util.List _jspx_dependants; public Object getDependants() { return _jspx_dependants; } public void _jspService(HttpServletRequest request, HttpServletResponse response) throws java.io.IOException, ServletException { JspFactory _jspxFactory = null; PageContext pageContext = null; HttpSession session = null; ServletContext application = null; ServletConfig config = null; JspWriter out = null; Object page = this; JspWriter _jspx_out = null; PageContext _jspx_page_context = null; try { _jspxFactory = JspFactory.getDefaultFactory(); response.setContentType("text/html; charset=UTF-8"); pageContext = _jspxFactory.getPageContext(this, request, response, null, true, 8192, true); _jspx_page_context = pageContext; application = pageContext.getServletContext(); config = pageContext.getServletConfig(); session = pageContext.getSession(); out = pageContext.getOut(); _jspx_out = out; out.write('\n'); out.write('\n'); JobTracker tracker = (JobTracker) application.getAttribute("job.tracker"); String trackerName = StringUtils.simpleHostname(tracker.getJobTrackerMachine()); String jobid = request.getParameter("jobid"); if (jobid == null) { out.println("

Missing 'jobid'!

"); return; } String type = request.getParameter("type"); String pagenum = request.getParameter("pagenum"); String state = request.getParameter("state"); state = (state!=null) ? state : "all"; int pnum = Integer.parseInt(pagenum); int next_page = pnum+1; int numperpage = 2000; JobID jobidObj = JobID.forName(jobid); JobInProgress job = (JobInProgress) tracker.getJob(jobidObj); 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(jobidObj) : null; } else if ("reduce".equals(type)) { reports = (job != null) ? tracker.getReduceTaskReports(jobidObj) : null; } else if ("cleanup".equals(type)) { reports = (job != null) ? tracker.getCleanupTaskReports(jobidObj) : null; } else if ("setup".equals(type)) { reports = (job != null) ? tracker.getSetupTaskReports(jobidObj) : null; } out.write("\n\n\n \n Hadoop "); out.print(type); out.write(" task list for "); out.print(jobid); out.write(" on "); out.print(trackerName); out.write("\n \n \n\n

Hadoop "); out.print(type); out.write(" task list for \n'); out.print(jobid); out.write(" on \n"); out.print(trackerName); out.write("

\n"); if (job == null) { out.print("Job " + jobid + " not found.
\n"); return; } // Filtering the reports if some filter is specified if (!"all".equals(state)) { List filteredReports = new ArrayList(); for (int i = 0; i < reports.length; ++i) { if (("completed".equals(state) && reports[i].getCurrentStatus() == TIPStatus.COMPLETE) || ("running".equals(state) && reports[i].getCurrentStatus() == TIPStatus.RUNNING) || ("killed".equals(state) && reports[i].getCurrentStatus() == TIPStatus.KILLED) || ("pending".equals(state) && reports[i].getCurrentStatus() == TIPStatus.PENDING)) { filteredReports.add(reports[i]); } } // using filtered reports instead of all the reports reports = filteredReports.toArray(new TaskReport[0]); filteredReports = null; } report_len = reports.length; if (report_len <= start_index) { out.print("No such tasks"); } else { out.print("
"); out.print("

" + Character.toUpperCase(state.charAt(0)) + state.substring(1).toLowerCase() + " 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) + ServletUtil.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" + "
"); } out.write("\n\n
\nGo back to JobTracker
\n"); out.println(ServletUtil.htmlFooter()); out.write('\n'); } catch (Throwable t) { if (!(t instanceof SkipPageException)){ out = _jspx_out; if (out != null && out.getBufferSize() != 0) out.clearBuffer(); if (_jspx_page_context != null) _jspx_page_context.handlePageException(t); } } finally { if (_jspxFactory != null) _jspxFactory.releasePageContext(_jspx_page_context); } } }