<%@ 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.*" %> <% String jobid = request.getParameter("jobid"); JobTracker tracker = JobTracker.getTracker(); JobInProgress job = (JobInProgress) tracker.getJob(jobid); JobProfile profile = (job != null) ? (job.getProfile()) : null; JobStatus status = (job != null) ? (job.getStatus()) : null; TaskReport[] mapTaskReports = (job != null) ? tracker.getMapTaskReports(jobid) : null; TaskReport[] reduceTaskReports = (job != null) ? tracker.getReduceTaskReports(jobid) : null; %> Hadoop MapReduce Job Details <% if (job == null) { %> No job found
<% } else { %>

Job '<%=jobid%>'

Job File: <%=profile.getJobFile()%>
The job started at: <%= new Date(job.getStartTime())%>
<% if (status.getRunState() == JobStatus.RUNNING) { out.print("The job is still running.
\n"); } else if (status.getRunState() == JobStatus.SUCCEEDED) { out.print("The job completed at: " + new Date(job.getFinishTime()) + "
\n"); } else if (status.getRunState() == JobStatus.FAILED) { out.print("The job failed at: " + new Date(job.getFinishTime()) + "
\n"); } %>

Map Tasks

<% for (int i = 0; i < mapTaskReports.length; i++) { TaskReport report = mapTaskReports[i]; out.print(""); out.print(""); out.print(""); String[] diagnostics = report.getDiagnostics(); for (int j = 0; j < diagnostics.length ; j++) { out.print(""); } out.print("\n"); } %>
Task IdCompleteStateErrors
" + report.getTaskId() + "" + report.getProgress() + "" + report.getState() + "" + diagnostics[j] + "

Reduce Tasks

<% for (int i = 0; i < reduceTaskReports.length; i++) { TaskReport report = reduceTaskReports[i]; out.print(""); out.print(""); out.print(""); String[] diagnostics = report.getDiagnostics(); for (int j = 0; j < diagnostics.length ; j++) { out.print(""); } out.print("\n"); } %>
Task IdCompleteStateErrors
" + report.getTaskId() + "" + report.getProgress() + "" + report.getState() + "" + diagnostics[j] + "
<% } %>
Go back to JobTracker
Hadoop, 2006.