[120] | 1 | <%@ page |
---|
| 2 | contentType="text/html; charset=UTF-8" |
---|
| 3 | import="javax.servlet.*" |
---|
| 4 | import="javax.servlet.http.*" |
---|
| 5 | import="java.io.*" |
---|
| 6 | import="java.util.*" |
---|
| 7 | import="java.text.DecimalFormat" |
---|
| 8 | import="org.apache.hadoop.mapred.*" |
---|
| 9 | import="org.apache.hadoop.util.*" |
---|
| 10 | %> |
---|
| 11 | <% |
---|
| 12 | TaskTracker tracker = (TaskTracker) application.getAttribute("task.tracker"); |
---|
| 13 | String trackerName = tracker.getName(); |
---|
| 14 | %> |
---|
| 15 | |
---|
| 16 | <html> |
---|
| 17 | |
---|
| 18 | <title><%= trackerName %> Task Tracker Status</title> |
---|
| 19 | |
---|
| 20 | <body> |
---|
| 21 | <h1><%= trackerName %> Task Tracker Status</h1> |
---|
| 22 | <img src="/static/hadoop-logo.jpg"/><br> |
---|
| 23 | <b>Version:</b> <%= VersionInfo.getVersion()%>, |
---|
| 24 | r<%= VersionInfo.getRevision()%><br> |
---|
| 25 | <b>Compiled:</b> <%= VersionInfo.getDate()%> by |
---|
| 26 | <%= VersionInfo.getUser()%><br> |
---|
| 27 | |
---|
| 28 | <h2>Running tasks</h2> |
---|
| 29 | <center> |
---|
| 30 | <table border=2 cellpadding="5" cellspacing="2"> |
---|
| 31 | <tr><td align="center">Task Attempts</td><td>Status</td> |
---|
| 32 | <td>Progress</td><td>Errors</td></tr> |
---|
| 33 | |
---|
| 34 | <% |
---|
| 35 | Iterator itr = tracker.getRunningTaskStatuses().iterator(); |
---|
| 36 | while (itr.hasNext()) { |
---|
| 37 | TaskStatus status = (TaskStatus) itr.next(); |
---|
| 38 | out.print("<tr><td>" + status.getTaskID()); |
---|
| 39 | out.print("</td><td>" + status.getRunState()); |
---|
| 40 | out.print("</td><td>" + |
---|
| 41 | StringUtils.formatPercent(status.getProgress(), 2)); |
---|
| 42 | out.print("</td><td><pre>" + status.getDiagnosticInfo() + "</pre></td>"); |
---|
| 43 | out.print("</tr>\n"); |
---|
| 44 | } |
---|
| 45 | %> |
---|
| 46 | </table> |
---|
| 47 | </center> |
---|
| 48 | |
---|
| 49 | <h2>Non-Running Tasks</h2> |
---|
| 50 | <table border=2 cellpadding="5" cellspacing="2"> |
---|
| 51 | <tr><td align="center">Task Attempts</td><td>Status</td> |
---|
| 52 | <% |
---|
| 53 | for(TaskStatus status: tracker.getNonRunningTasks()) { |
---|
| 54 | out.print("<tr><td>" + status.getTaskID() + "</td>"); |
---|
| 55 | out.print("<td>" + status.getRunState() + "</td></tr>\n"); |
---|
| 56 | } |
---|
| 57 | %> |
---|
| 58 | </table> |
---|
| 59 | |
---|
| 60 | |
---|
| 61 | <h2>Tasks from Running Jobs</h2> |
---|
| 62 | <center> |
---|
| 63 | <table border=2 cellpadding="5" cellspacing="2"> |
---|
| 64 | <tr><td align="center">Task Attempts</td><td>Status</td> |
---|
| 65 | <td>Progress</td><td>Errors</td></tr> |
---|
| 66 | |
---|
| 67 | <% |
---|
| 68 | itr = tracker.getTasksFromRunningJobs().iterator(); |
---|
| 69 | while (itr.hasNext()) { |
---|
| 70 | TaskStatus status = (TaskStatus) itr.next(); |
---|
| 71 | out.print("<tr><td>" + status.getTaskID()); |
---|
| 72 | out.print("</td><td>" + status.getRunState()); |
---|
| 73 | out.print("</td><td>" + |
---|
| 74 | StringUtils.formatPercent(status.getProgress(), 2)); |
---|
| 75 | out.print("</td><td><pre>" + status.getDiagnosticInfo() + "</pre></td>"); |
---|
| 76 | out.print("</tr>\n"); |
---|
| 77 | } |
---|
| 78 | %> |
---|
| 79 | </table> |
---|
| 80 | </center> |
---|
| 81 | |
---|
| 82 | |
---|
| 83 | <h2>Local Logs</h2> |
---|
| 84 | <a href="/logs/">Log</a> directory |
---|
| 85 | |
---|
| 86 | <% |
---|
| 87 | out.println(ServletUtil.htmlFooter()); |
---|
| 88 | %> |
---|