You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-dev@hadoop.apache.org by "stanley shi (JIRA)" <ji...@apache.org> on 2014/08/19 08:52:18 UTC

[jira] [Created] (MAPREDUCE-6039) mapreduce.v2.hs.webapp.dao.TestJobInfo is using old name of job history file

stanley shi created MAPREDUCE-6039:
--------------------------------------

             Summary: mapreduce.v2.hs.webapp.dao.TestJobInfo is using old name of job history file
                 Key: MAPREDUCE-6039
                 URL: https://issues.apache.org/jira/browse/MAPREDUCE-6039
             Project: Hadoop Map/Reduce
          Issue Type: Bug
    Affects Versions: 2.4.1
            Reporter: stanley shi


In the file: org.apache.hadoop.mapreduce.v2.hs.webapp.dao.TestJobInfo.java, there's an example job history file named "job_1329348432655_0001-1329348443227-user-Sleep+job-1329348468601-10-1-SUCCEEDED-default.jhist"; 
This name is no longer valid since the change of MAPREDUCE-5052, which added the "startTime" of the job to the end of the job history file name, which makes the name should be like: job_1329348432655_0001-1329348443227-user-Sleep+job-1329348468601-10-1-SUCCEEDED-default-1329348464601.jhist

The code in TestJobInfo.java: {code}
public void testAverageMergeTime() throws IOException {
    String historyFileName =
        "job_1329348432655_0001-1329348443227-user-Sleep+job-1329348468601-10-1-SUCCEEDED-default.jhist";
    String confFileName =
        "job_1329348432655_0001_conf.xml";
    Configuration conf = new Configuration();
    JobACLsManager jobAclsMgr = new JobACLsManager(conf);
    Path fulleHistoryPath =
        new Path(TestJobHistoryEntities.class.getClassLoader()
            .getResource(historyFileName)
            .getFile());
    Path fullConfPath =
        new Path(TestJobHistoryEntities.class.getClassLoader()
            .getResource(confFileName)
            .getFile());

    HistoryFileInfo info = mock(HistoryFileInfo.class);
    when(info.getConfFile()).thenReturn(fullConfPath);

    JobId jobId = MRBuilderUtils.newJobId(1329348432655l, 1, 1);
    CompletedJob completedJob =
        new CompletedJob(conf, jobId, fulleHistoryPath, true, "user",
            info, jobAclsMgr);
    JobInfo jobInfo = new JobInfo(completedJob);
    // There are 2 tasks with merge time of 45 and 55 respectively. So average
    // merge time should be 50.
    Assert.assertEquals(50L, jobInfo.getAvgMergeTime().longValue());
  }
{code}



--
This message was sent by Atlassian JIRA
(v6.2#6252)