<%! /** * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ %> <%@ page import="javax.servlet.*" import="javax.servlet.http.*" import="java.io.*" import="java.lang.String" import="java.text.*" import="java.util.*" import="org.apache.hadoop.http.HtmlQuoting" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.mapred.JSPUtil.JobWithViewAccessCheck" import="org.apache.hadoop.util.*" import="java.text.SimpleDateFormat" import="org.codehaus.jackson.map.ObjectMapper" %> <%! private static final long serialVersionUID = 1L; %> <%! public static class ErrorResponse { private final long errorCode; private final String errorDescription; // Constructor ErrorResponse(long ec, String ed) { errorCode = ec; errorDescription = ed; } // Getters public long getErrorCode() { return errorCode; } public String getErrorDescription() { return errorDescription; } } public static class TaskStatsResponse { public static class TaskCounterGroupInfo { public static class TaskCounterInfo { private final String name; private final long value; // Constructor TaskCounterInfo(Counters.Counter c) { name = c.getDisplayName(); value = c.getCounter(); } // Getters public String getName() { return name; } public long getValue() { return value; } } private final String groupName; private final Collection taskCountersInfo; // Constructor TaskCounterGroupInfo(String gn) { groupName = gn; taskCountersInfo = new ArrayList(); } // To add one TaskCounterInfo object at a time. void addTaskCounterInfo(TaskCounterInfo tci) { taskCountersInfo.add(tci); } // Getters public String getGroupName() { return groupName; } public Collection getTaskCountersInfo() { return taskCountersInfo; } } private final String taskId; private final Collection taskCounterGroupsInfo; // Constructor TaskStatsResponse(String ti) { taskId = ti; taskCounterGroupsInfo = new ArrayList(); } // To add one TaskCounterGroupInfo object at a time. void addTaskCounterGroupInfo(TaskCounterGroupInfo tcgi) { taskCounterGroupsInfo.add(tcgi); } // Getters public String getTaskId() { return taskId; } public Collection getTaskCounterGroupsInfo() { return taskCounterGroupsInfo; } } %> <% String response_format = request.getParameter("format"); if (response_format != null) { /* Eventually, the HTML output should also be driven off of these *Response * objects. * * Someday. */ TaskStatsResponse theTaskStatsResponse = null; ErrorResponse theErrorResponse = null; JobTracker tracker = (JobTracker) application.getAttribute("job.tracker"); String attemptid = request.getParameter("attemptid"); String tipid = request.getParameter("tipid"); /* Make sure at least one of the 2 possible query parameters were specified. */ if ((attemptid != null) || (tipid != null)) { TaskAttemptID attemptidObj = TaskAttemptID.forName(attemptid); // Obtain tipid for attemptId, if attemptId is available. TaskID tipidObj = (attemptidObj == null) ? TaskID.forName(tipid) : attemptidObj.getTaskID(); if (tipidObj != null) { // Obtain jobid from tipid final JobID jobidObj = tipidObj.getJobID(); String jobid = jobidObj.toString(); JobWithViewAccessCheck myJob = JSPUtil.checkAccessAndGetJob(tracker, jobidObj, request, response); /* Proceed only if the user is authorized to view this job. */ if (myJob.isViewJobAllowed()) { JobInProgress job = myJob.getJob(); if (job != null) { Counters counters; if (attemptid == null) { counters = tracker.getTipCounters(tipidObj); attemptid = tipidObj.toString(); } else { TaskStatus taskStatus = tracker.getTaskStatus(attemptidObj); counters = taskStatus.getCounters(); } if (counters != null) { theTaskStatsResponse = new TaskStatsResponse(attemptid); for (String groupName : counters.getGroupNames()) { Counters.Group group = counters.getGroup(groupName); TaskStatsResponse.TaskCounterGroupInfo taskCounterGroupInfo = new TaskStatsResponse.TaskCounterGroupInfo(group.getDisplayName()); for (Counters.Counter counter : group) { taskCounterGroupInfo.addTaskCounterInfo (new TaskStatsResponse.TaskCounterGroupInfo.TaskCounterInfo (counter)); } theTaskStatsResponse.addTaskCounterGroupInfo(taskCounterGroupInfo); } } else { response.setStatus(HttpServletResponse.SC_NOT_FOUND); theErrorResponse = new ErrorResponse(4103, "Counters For " + attemptid + " Not Found"); } } else { response.setStatus(HttpServletResponse.SC_NOT_FOUND); theErrorResponse = new ErrorResponse(4102, "JobID " + jobid + " Not Found"); } } else { /* TODO XXX Try and factor out JSPUtil.setErrorAndForward() for re-use * (and to not make it blindly dispatch to job_authorization_error.jsp, * which is all HTML. */ /* TODO XXX Make this return JSON, not HTML. */ /* Nothing to do here, since JSPUtil.setErrorAndForward() has already been * called from inside JSPUtil.checkAccessAndGetJob(). */ } } else { response.setStatus(HttpServletResponse.SC_NOT_FOUND); theErrorResponse = new ErrorResponse(4101, ((attemptid == null) ? ("TipID " + tipid) : ("AttemptID " + attemptid)) + " Invalid"); } } else { response.setStatus(HttpServletResponse.SC_BAD_REQUEST); theErrorResponse = new ErrorResponse(4100, "Missing TipID/AttemptID"); } /* ------------ Response generation begins here ------------ */ /* For now, "json" is the only supported format. * * As more formats are supported, this should become a cascading * if-elsif-else block. */ if ("json".equals(response_format)) { response.setContentType("application/json"); ObjectMapper responseObjectMapper = new ObjectMapper(); /* A lack of an error response implies we have a meaningful * application response? Why not! */ out.println(responseObjectMapper.writeValueAsString ((theErrorResponse == null) ? theTaskStatsResponse : theErrorResponse)); } else { response.setStatus(HttpServletResponse.SC_NOT_IMPLEMENTED); } } else { %> <% // Spit out HTML only in the absence of the "format" query parameter. response.setContentType("text/html; charset=UTF-8"); JobTracker tracker = (JobTracker) application.getAttribute("job.tracker"); String attemptid = request.getParameter("attemptid"); TaskAttemptID attemptidObj = TaskAttemptID.forName(attemptid); // Obtain tipid for attemptId, if attemptId is available. TaskID tipidObj = (attemptidObj == null) ? TaskID.forName(request.getParameter("tipid")) : attemptidObj.getTaskID(); // Obtain jobid from tipid final JobID jobidObj = tipidObj.getJobID(); String jobid = jobidObj.toString(); JobWithViewAccessCheck myJob = JSPUtil.checkAccessAndGetJob(tracker, jobidObj, request, response); if (!myJob.isViewJobAllowed()) { return; // user is not authorized to view this job } JobInProgress job = myJob.getJob(); if (job == null) { out.print("Job " + jobid + " not found.
\n"); return; } Format decimal = new DecimalFormat(); Counters counters; if (attemptid == null) { counters = tracker.getTipCounters(tipidObj); attemptid = tipidObj.toString(); // for page title etc } else { TaskStatus taskStatus = tracker.getTaskStatus(attemptidObj); counters = taskStatus.getCounters(); } %> Counters for <%=attemptid%>

Counters for <%=attemptid%>

<% if ( counters == null ) { %>

No counter information found for this task

<% } else { %> <% for (String groupName : counters.getGroupNames()) { Counters.Group group = counters.getGroup(groupName); String displayGroupName = group.getDisplayName(); %> <% for (Counters.Counter counter : group) { String displayCounterName = counter.getDisplayName(); long value = counter.getCounter(); %> <% } } %>

<%=HtmlQuoting.quoteHtmlChars(displayGroupName)%>
<%=HtmlQuoting.quoteHtmlChars(displayCounterName)%> <%=decimal.format(value)%>
<% } %>
Go back to the job
Go back to JobTracker
<% out.println(ServletUtil.htmlFooter()); %> <% } // if (response_format != null) %>