<% /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you 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 contentType="text/html; charset=UTF-8" import="javax.servlet.http.*" import="java.io.*" import="java.util.*" import="org.apache.hadoop.mapred.*" import="org.apache.hadoop.fs.*" import="org.apache.hadoop.util.*" import="java.text.*" import="org.apache.hadoop.mapreduce.jobhistory.*" import="org.apache.hadoop.mapreduce.TaskID" import="org.apache.hadoop.mapreduce.TaskAttemptID" import="org.apache.hadoop.mapreduce.Counter" import="org.apache.hadoop.mapreduce.Counters" import="org.apache.hadoop.mapreduce.CounterGroup" %> <%! private static SimpleDateFormat dateFormat = new SimpleDateFormat("d/MM HH:mm:ss") ; private static final long serialVersionUID = 1L; %> <% String jobid = request.getParameter("jobid"); String attemptid = request.getParameter("attemptid"); String taskid = request.getParameter("taskid"); String logFile = request.getParameter("logFile"); Format decimal = new DecimalFormat(); FileSystem fs = (FileSystem) application.getAttribute("fileSys"); JobHistoryParser.JobInfo job = JSPUtil.getJobInfo(request, fs); Map tasks = job.getAllTasks(); JobHistoryParser.TaskInfo task = tasks.get(TaskID.forName(taskid)); Map attempts = task.getAllTaskAttempts(); JobHistoryParser.TaskAttemptInfo attempt = attempts.get(TaskAttemptID.forName(attemptid)); Counters counters = attempt.getCounters(); %> Counters for <%=attemptid%>

Counters for <%=attemptid%>

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

No counter information found for this attempt

<% } else { %> <% for (String groupName : counters.getGroupNames()) { CounterGroup group = counters.getGroup(groupName); String displayGroupName = group.getDisplayName(); %> <% Iterator ctrItr = group.iterator(); while(ctrItr.hasNext()) { Counter counter = ctrItr.next(); String displayCounterName = counter.getDisplayName(); long value = counter.getValue(); %> <% } } %>

<%=displayGroupName%>
<%=displayCounterName%> <%=decimal.format(value)%>
<% } %>
Go back to the job
Go back to JobTracker
<% out.println(ServletUtil.htmlFooter()); %>