private void readJobInformation ( JobConf jobConf , JobInfo jobInfo ) throws Exception { /* * Convert the input strings to URL */ URL jobConfFileUrl = new URL ( this . _jobConfFile ) ; URL jobHistoryFileUrl = new URL ( this . _jobHistoryFile ) ; /* * Read the Job Configuration from the jobConfFile url */ jobConf . addResource ( jobConfFileUrl ) ; /* * Read JobHistoryFile and build job counters to evaluate diagnostic rules */ if ( jobHistoryFileUrl . getProtocol ( ) . equals ( "hdfs" ) ) { DefaultJobHistoryParser . parseJobTasks ( jobHistoryFileUrl . getPath ( ) , jobInfo , FileSystem . get ( jobConf ) ) ; } else if ( jobHistoryFileUrl . getProtocol ( ) . equals ( "file" ) ) { DefaultJobHistoryParser . parseJobTasks ( jobHistoryFileUrl . getPath ( ) , jobInfo , FileSystem . getLocal ( jobConf ) ) ; } else { throw new Exception ( "Malformed URL. Protocol: " + jobHistoryFileUrl . getProtocol ( ) ) ; } }
read and populate job statistics information .