📄 jobfailures.jsp

📁 hadoop:Nutch集群平台
💻 JSP
字号:
<%@ 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.*"  import="org.apache.hadoop.util.*"%><%!  JobTracker tracker = JobTracker.getTracker();  String trackerName =            StringUtils.simpleHostname(tracker.getJobTrackerMachine());    private void printFailedAttempts(JspWriter out,                                   String jobId,                                   TaskInProgress tip) throws IOException {    TaskStatus[] statuses = tip.getTaskStatuses();    String tipId = tip.getTIPId();    for(int i=0; i < statuses.length; ++i) {      if (statuses[i].getRunState() == TaskStatus.State.FAILED) {        String taskTrackerName = statuses[i].getTaskTracker();        TaskTrackerStatus taskTracker = tracker.getTaskTracker(taskTrackerName);        out.print("<tr><td>" + statuses[i].getTaskId() +                  "</td><td><a href=\"/taskdetails.jsp?jobid="+ jobId +                   "&taskid=" + tipId + "\">" + tipId +                  "</a></td>");        if (taskTracker == null) {          out.print("<td>" + taskTrackerName + "</td>");        } else {          out.print("<td><a href=\"http://" + taskTracker.getHost() + ":" +                    taskTracker.getHttpPort() + "\">" +  taskTracker.getHost() +                     "</a></td>");        }        out.print("<td><pre>");        List<String> failures =                      tracker.getTaskDiagnostics(jobId, tipId,                                                 statuses[i].getTaskId());        if (failures == null) {          out.print("&nbsp;");        } else {          for(Iterator<String> itr = failures.iterator(); itr.hasNext(); ) {            out.print(itr.next());            if (itr.hasNext()) {              out.print("\n-------\n");            }           }         }         out.print("</pre></td></tr>\n");       }    }  }               private void printFailures(JspWriter out,                              String jobId,                             String kind) throws IOException {    JobInProgress job = (JobInProgress) tracker.getJob(jobId);    if (job == null) {      out.print("<b>Job " + jobId + " not found.</b><br>\n");      return;    }    boolean includeMap = false;    boolean includeReduce = false;    if (kind == null) {      includeMap = true;      includeReduce = true;    } else if ("map".equals(kind)) {      includeMap = true;    } else if ("reduce".equals(kind)) {      includeReduce = true;    } else if ("all".equals(kind)) {      includeMap = true;      includeReduce = true;    } else {      out.print("<b>Kind " + kind + " not supported.</b><br>\n");      return;    }    out.print("<table border=2 cellpadding=\"5\" cellspacing=\"2\">");    out.print("<tr><th>Attempt</th><th>Task</th><th>Machine</th>" +              "<th>Error</th></tr>\n");    if (includeMap) {      TaskInProgress[] tips = job.getMapTasks();      for(int i=0; i < tips.length; ++i) {        printFailedAttempts(out, jobId, tips[i]);      }    }    if (includeReduce) {      TaskInProgress[] tips = job.getReduceTasks();      for(int i=0; i < tips.length; ++i) {        printFailedAttempts(out, jobId, tips[i]);      }    }    out.print("</table>\n");  }%><%    String jobId = request.getParameter("jobid");    String kind = request.getParameter("kind");%><html><title>Hadoop <%=jobId%> failures on <%=trackerName%></title><body><h1>Hadoop <a href="/jobdetails.jsp?jobid=<%=jobId%>"><%=jobId%></a>failures on <a href="/jobtracker.jsp"><%=trackerName%></a></h1><%     printFailures(out, jobId, kind); %><hr><a href="/jobtracker.jsp">Go back to JobTracker</a><br><a href="http://lucene.apache.org/hadoop">Hadoop</a>, 2006.<br></body></html>
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -