jobconf_history.jsp
上传用户:quxuerui
上传日期:2018-01-08
资源大小:41811k
文件大小:1k
源码类别:

网格计算

开发平台:

Java

  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.net.URL"
  7.   import="org.apache.hadoop.mapred.*"
  8.   import="org.apache.hadoop.fs.*"
  9.   import="org.apache.hadoop.util.*"
  10. %>
  11. <%
  12.   JobTracker tracker = (JobTracker) application.getAttribute("job.tracker");
  13.   String jobId = request.getParameter("jobid");
  14.   if (jobId == null) {
  15.     out.println("<h2>Missing 'jobid' for fetching job configuration!</h2>");
  16.   return;
  17.   }
  18. %>
  19.   
  20. <html>
  21. <title>Job Configuration: JobId - <%= jobId %></title>
  22. <body>
  23. <h2>Job Configuration: JobId - <%= jobId %></h2><br>
  24. <%
  25.   Path logDir = new Path(request.getParameter("jobLogDir"));
  26.   Path jobFilePath = new Path(logDir, 
  27.                        request.getParameter("jobUniqueString") + "_conf.xml");
  28.   FileSystem fs = (FileSystem)request.getSession().getAttribute("fs");
  29.   FSDataInputStream jobFile = null; 
  30.   try {
  31.     jobFile = fs.open(jobFilePath);
  32.     JobConf jobConf = new JobConf(jobFilePath);
  33.     XMLUtils.transform(
  34.         jobConf.getConfResourceAsInputStream("webapps/static/jobconf.xsl"),
  35.         jobFile, out);
  36.   } catch (Exception e) {
  37.     out.println("Failed to retreive job configuration for job '" + jobId + "!");
  38.     out.println(e);
  39.   } finally {
  40.     if (jobFile != null) {
  41.       try { 
  42.         jobFile.close(); 
  43.       } catch (IOException e) {}
  44.     }
  45.   } 
  46. %>
  47. <br>
  48. <%
  49. out.println(ServletUtil.htmlFooter());
  50. %>