<%@ page contentType="text/html; charset=UTF-8" import="javax.servlet.*" import="javax.servlet.http.*" import="java.io.*" import="java.util.*" import="java.text.DecimalFormat" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.util.*" %> <% JobTracker tracker = (JobTracker) application.getAttribute("job.tracker"); String trackerName = StringUtils.simpleHostname(tracker.getJobTrackerMachine()); %> <%! public void generateTaskTrackerTable(JspWriter out, JobTracker tracker) throws IOException { Collection c = tracker.taskTrackers(); if (c.size() == 0) { out.print("There are currently no known Task Trackers."); } else { out.print("
\n"); out.print("\n"); out.print("\n"); out.print("" + "" + "\n"); int maxFailures = 0; String failureKing = null; for (Iterator it = c.iterator(); it.hasNext(); ) { TaskTrackerStatus tt = (TaskTrackerStatus) it.next(); long sinceHeartbeat = System.currentTimeMillis() - tt.getLastSeen(); if (sinceHeartbeat > 0) { sinceHeartbeat = sinceHeartbeat / 1000; } int numCurTasks = 0; for (Iterator it2 = tt.getTaskReports().iterator(); it2.hasNext(); ) { it2.next(); numCurTasks++; } int numFailures = tt.getFailures(); if (numFailures > maxFailures) { maxFailures = numFailures; failureKing = tt.getTrackerName(); } out.print("\n"); } out.print("
Task Trackers
NameHost# running tasksFailuresSeconds since heartbeat
"); out.print(tt.getTrackerName() + ""); out.print(tt.getHost() + "" + numCurTasks + "" + numFailures + "" + sinceHeartbeat + "
\n"); out.print("
\n"); if (maxFailures > 0) { out.print("Highest Failures: " + failureKing + " with " + maxFailures + " failures
\n"); } } } %> <%=trackerName%> Hadoop Machine List

<%=trackerName%> Hadoop Machine List

Task Trackers

<% generateTaskTrackerTable(out, tracker); %>
Hadoop, 2007.