%@ page contentType="text/html; charset=UTF-8" import="javax.servlet.*" import="javax.servlet.http.*" import="java.io.*" import="java.lang.String" import="java.util.*" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.util.*" import="java.text.SimpleDateFormat" import="org.apache.hadoop.util.*" %> <%! static SimpleDateFormat dateFormat = new SimpleDateFormat("d-MMM-yyyy HH:mm:ss") ; %> <% String jobid = request.getParameter("jobid"); JobTracker tracker = JobTracker.getTracker(); JobInProgress job = (JobInProgress) tracker.getJob(jobid); String tipid = request.getParameter("tipid"); TaskStatus[] ts = (job != null) ? tracker.getTaskStatuses(jobid, tipid): null; %>
Task Attempts | Machine | Status | Progress | Start Time | <% if( ! ts[0].getIsMap() ) { %>Shuffle Finished | Sort Finished | <% } %>Finish Time | Errors | Task Logs | Counters | |
" + status.getTaskId() + " | "); String taskAttemptTracker = null; if (taskTracker == null) { out.print("" + taskTrackerName + " | "); } else { taskAttemptTracker = "http://" + taskTracker.getHost() + ":" + taskTracker.getHttpPort(); out.print("" + taskTracker.getHost() + " | "); } out.print("" + status.getRunState() + " | "); out.print(""+ StringUtils.formatPercent(status.getProgress(),2) + " | "); out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, status.getStartTime(), 0) + " | "); if( ! ts[i].getIsMap() ) { out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, status.getShuffleFinishTime(), status.getStartTime()) + " | "); out.println("" + StringUtils.getFormattedTimeWithDiff(dateFormat, status.getSortFinishTime(), status.getShuffleFinishTime()) + " | "); } out.println(""+ StringUtils.getFormattedTimeWithDiff(dateFormat, status.getFinishTime(), status.getStartTime()) + " | "); out.print(""); List | ");
out.print("");
if (taskAttemptTracker == null) {
out.print("n/a");
} else {
String taskLogUrl = taskAttemptTracker + "/tasklog?taskid=" +
status.getTaskId();
String tailFourKBUrl = taskLogUrl + "&start=-4097";
String tailEightKBUrl = taskLogUrl + "&start=-8193";
String entireLogUrl = taskLogUrl + "&all=true";
out.print("Last 4KB "); out.print("Last 8KB "); out.print("All "); } out.println(" | " + "" + status.getCounters().size() + " |