%@ 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"); private static final String PRIVATE_ACTIONS_KEY = "webinterface.private.actions";%> <%!private void printConfirm(JspWriter out, String jobid, String tipid, String taskid, String action) throws IOException { String url = "taskdetails.jsp?jobid=" + jobid + "&tipid=" + tipid + "&taskid=" + taskid; out.print("
" + "" + "" + " |
Task Attempts | Machine | Status | Progress | Start Time | <% if (!ts[0].getIsMap() && !isCleanupOrSetup) { %>Shuffle Finished | Sort Finished | <% } %>Finish Time | Errors | Task Logs | Counters | Actions |
" + status.getTaskID() + " | "); String taskAttemptTracker = null; String cleanupTrackerName = null; TaskTrackerStatus cleanupTracker = null; String cleanupAttemptTracker = null; boolean hasCleanupAttempt = false; if (tip != null && tip.isCleanupAttempt(status.getTaskID())) { cleanupTrackerName = tip.machineWhereCleanupRan(status.getTaskID()); cleanupTracker = tracker.getTaskTracker(cleanupTrackerName); if (cleanupTracker != null) { cleanupAttemptTracker = "http://" + cleanupTracker.getHost() + ":" + cleanupTracker.getHttpPort(); } hasCleanupAttempt = true; } out.print("");
if (hasCleanupAttempt) {
out.print("Task attempt: ");
}
if (taskTracker == null) {
out.print(taskTrackerName);
} else {
taskAttemptTracker = "http://" + taskTracker.getHost() + ":"
+ taskTracker.getHttpPort();
out.print(""
+ tracker.getNode(taskTracker.getHost()) + "");
}
if (hasCleanupAttempt) {
out.print(" Cleanup Attempt: "); if (cleanupAttemptTracker == null ) { out.print(cleanupTrackerName); } else { out.print("" + tracker.getNode(cleanupTracker.getHost()) + ""); } } out.print(" | ");
out.print("" + status.getRunState() + " | "); out.print("" + StringUtils.formatPercent(status.getProgress(), 2) + ServletUtil.percentageGraph(status.getProgress() * 100f, 80) + " | "); out.print("" + StringUtils.getFormattedTimeWithDiff(dateFormat, status .getStartTime(), 0) + " | "); if (!ts[i].getIsMap() && !isCleanupOrSetup) { 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(""); String [] failures = tracker.getTaskDiagnostics(status.getTaskID()); if (failures == null) { out.print(" "); } else { for(int j = 0 ; j < failures.length ; j++){ out.print(failures[j]); if (j < (failures.length - 1)) { out.print("\n-------\n"); } } } out.print(" | ");
out.print("");
String taskLogUrl = null;
if (taskTracker != null ) {
taskLogUrl = TaskLogServlet.getTaskLogUrl(taskTracker.getHost(),
String.valueOf(taskTracker.getHttpPort()),
status.getTaskID().toString());
}
if (hasCleanupAttempt) {
out.print("Task attempt: "); } if (taskLogUrl == null) { out.print("n/a"); } else { 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 "); } if (hasCleanupAttempt) { out.print("Cleanup attempt: "); taskLogUrl = null; if (cleanupTracker != null ) { taskLogUrl = TaskLogServlet.getTaskLogUrl(cleanupTracker.getHost(), String.valueOf(cleanupTracker.getHttpPort()), status.getTaskID().toString()); } if (taskLogUrl == null) { out.print("n/a"); } else { String tailFourKBUrl = taskLogUrl + "&start=-4097&cleanup=true"; String tailEightKBUrl = taskLogUrl + "&start=-8193&cleanup=true"; String entireLogUrl = taskLogUrl + "&all=true&cleanup=true"; out.print("Last 4KB "); out.print("Last 8KB "); out.print("All "); } } out.print(" | " + "" + ((status.getCounters() != null) ? status.getCounters().size() : 0) + " | "); out.print("");
if (privateActions
&& status.getRunState() == TaskStatus.State.RUNNING) {
out.print(" Kill ");
out.print(" Fail "); } else out.print(" "); out.println(" |
" + split + " |