%@ 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
Task Id | Complete | State | Errors |
<%
for (int i = 0; i < mapTaskReports.length; i++) {
TaskReport report = mapTaskReports[i];
out.print("" + report.getTaskId() + " | ");
out.print("" + report.getProgress() + " | ");
out.print("" + report.getState() + " | ");
String[] diagnostics = report.getDiagnostics();
for (int j = 0; j < diagnostics.length ; j++) {
out.print("" + diagnostics[j] + " | ");
}
out.print("
\n");
}
%>
Reduce Tasks
Task Id | Complete | State | Errors |
<%
for (int i = 0; i < reduceTaskReports.length; i++) {
TaskReport report = reduceTaskReports[i];
out.print("" + report.getTaskId() + " | ");
out.print("" + report.getProgress() + " | ");
out.print("" + report.getState() + " | ");
String[] diagnostics = report.getDiagnostics();
for (int j = 0; j < diagnostics.length ; j++) {
out.print("" + diagnostics[j] + " | ");
}
out.print("
\n");
}
%>
<%
}
%>
Go back to JobTracker
Hadoop, 2006.